Package com.hp.hpl.jena.tdb.base.block

Examples of com.hp.hpl.jena.tdb.base.block.BlockMgr

50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
        BlockMgrTracker.verbose = b ;
    }   
   
    @Test public void track_01()
    {
        BlockMgr mgr = BlockMgrFactory.createMem("BPTRecord", 4) ;
        mgr = BlockMgrFactory.tracker(mgr) ;
        mgr.beginUpdate() ;
        Block block = mgr.allocate(4) ;
        ByteBuffer bb = block.getByteBuffer() ;
        bb.putInt(0,1234) ;
        mgr.write(block) ;
        mgr.release(block) ;
        // -----
        Block block2 = mgr.getRead(block.getId()) ;
        ByteBuffer bb2 = block2.getByteBuffer() ;
        assertArrayEquals(bb.array(), bb2.array()) ;
        mgr.release(block2) ;
        mgr.endUpdate() ;
    }
View Full Code Here
69
70
71
72
73
74
75
76
77
    }

    // Multiple overlapping read operations.
    static BlockMgr setup()
    {
        BlockMgr mgr = BlockMgrFactory.createMem("BPTRecord", 4) ;
        mgr = BlockMgrFactory.tracker(mgr) ;
        return mgr ;
    }
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
        mgr.endUpdate() ;
    }
   
    @Test public void track_02()
    {
        BlockMgr mgr = setup() ;
        write(mgr, 1234) ;
        write(mgr, 5678) ;

        mgr.beginRead() ;
        mgr.beginRead() ;

        Block b0 = mgr.getRead(0) ;
        Block b1 = mgr.getRead(1) ;
       
        mgr.release(b1) ;
        mgr.release(b0) ;
       
        mgr.endRead() ;
        mgr.endRead() ;
    }
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
118
119
    }
   
    @Test(expected=BlockException.class)
    public void track_03()
    {
        BlockMgr mgr = setup() ;
        write(mgr, 1234) ;
        write(mgr, 5678) ;

        mgr.beginRead() ;
        Block b0 = mgr.getWrite(0) ;
        mgr.endRead() ;
    }
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
130
    }

    @Test(expected=BlockException.class)
    public void track_04()
    {
        BlockMgr mgr = setup() ;
        write(mgr, 1234) ;
        mgr.beginRead() ;
        Block b0 = mgr.getRead(0) ;
        mgr.promote(b0) ;
        mgr.endRead() ;
    }
View Full Code Here
130
131
132
133
134
135
136
137
138
    }

    @Test(expected=BlockException.class)
    public void track_05()
    {
        BlockMgr mgr = setup() ;
        mgr.beginRead() ;
        mgr.endUpdate() ;
    }
View Full Code Here
138
139
140
141
142
143
144
145
146
    }

    @Test(expected=BlockException.class)
    public void track_06()
    {
        BlockMgr mgr = setup() ;
        mgr.beginUpdate() ;
        mgr.endRead() ;
    }
View Full Code Here
387
388
389
390
391
392
393
394
395
396
        }
       
        @Override
        public BlockMgr buildBlockMgr(FileSet fileSet, String ext, int blockSize)
        {
            BlockMgr blkMgr = builder.buildBlockMgr(fileSet, ext, blockSize) ;
            FileRef ref = FileRef.create(fileSet, ext) ;
            recorder.record(ref, blkMgr) ;
            return blkMgr ;
        }
View Full Code Here
286
287
288
289
290
291
292
293
294
295
296
297
       
        int readCacheSize = 10 ;
        int writeCacheSize = 100 ;
       
        FileSet destination = new FileSet(location, indexName) ;
        BlockMgr blkMgrNodes = BlockMgrFactory.create(destination, Names.bptExtTree, SystemTDB.BlockSize, readCacheSize, writeCacheSize) ;
        BlockMgr blkMgrRecords = BlockMgrFactory.create(destination, Names.bptExtRecords, SystemTDB.BlockSize, readCacheSize, writeCacheSize) ;
       
        cmdLog.info("Index: creating " + indexName + " index...") ;
        final ProgressLogger monitor = new ProgressLogger(cmdLog, "records to " + indexName, BulkLoader.DataTickPoint,BulkLoader.superTick) ;
        monitor.start() ;
       
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
156
    int order = BPlusTreeParams.calcOrder(SystemTDB.BlockSize, recordFactory) ;
    BPlusTreeParams bptParams = new BPlusTreeParams(order, recordFactory) ;
    int readCacheSize = 10 ;
    int writeCacheSize = 100 ;
    FileSet destination = new FileSet(location, Names.indexNode2Id) ;
    BlockMgr blkMgrNodes = BlockMgrFactory.create(destination, Names.bptExtTree, SystemTDB.BlockSize, readCacheSize, writeCacheSize) ;
    BlockMgr blkMgrRecords = BlockMgrFactory.create(destination, Names.bptExtRecords, SystemTDB.BlockSize, readCacheSize, writeCacheSize) ;
    Iterator<Record> iter2 = Iter.iter(sortedDataBag.iterator()).map(transformPair2Record) ;
      BPlusTree bpt2 = BPlusTreeRewriter.packIntoBPlusTree(iter2, bptParams, recordFactory, blkMgrNodes, blkMgrRecords) ;
      bpt2.sync() ;
      bpt2.close() ;
   
View Full Code Here
TOP

Related Classes of com.hp.hpl.jena.tdb.base.block.BlockMgr

  • com.hp.hpl.jena.tdb.base.block.TestBlockMgrTracked
  • com.hp.hpl.jena.tdb.base.recordfile.TestRecordBufferPage
  • com.hp.hpl.jena.tdb.index.bplustree.BPlusTree
  • com.hp.hpl.jena.tdb.index.bplustree.BPlusTreeTools
  • com.hp.hpl.jena.tdb.index.bplustree.TestBPlusTreeRewriter
  • com.hp.hpl.jena.tdb.index.ext.ExtHash
  • com.hp.hpl.jena.tdb.index.ext.TestExtHash
  • com.hp.hpl.jena.tdb.index.factories.IndexFactoryBPlusTree
  • com.hp.hpl.jena.tdb.index.factories.IndexFactoryExtHash
  • com.hp.hpl.jena.tdb.setup.Builder$BlockMgrBuilderStd
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.