Home
last modified time | relevance | path

Searched refs:cfHandles (Results 1 – 12 of 12) sorted by relevance

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DRocksDBTest.java81 cfHandles)) { in createColumnFamily() argument
88 cfHandles) { in createColumnFamily()
101 List<ColumnFamilyHandle> cfHandles; in createColumnFamilies() local
105 cfHandles = in createColumnFamilies()
119 cfHandles = new ArrayList<>(); in createColumnFamilies()
125 cfHandles)) { in createColumnFamilies() argument
145 List<ColumnFamilyHandle> cfHandles; in createColumnFamiliesfromDescriptors() local
149 cfHandles = in createColumnFamiliesfromDescriptors()
165 cfHandles = new ArrayList<>(); in createColumnFamiliesfromDescriptors()
171 cfHandles)) { in createColumnFamiliesfromDescriptors() argument
[all …]
DCompactionFilterFactoryTest.java40 final List<ColumnFamilyHandle> cfHandles = new ArrayList<>(); in columnFamilyOptions_setCompactionFilterFactory() local
43 dbFolder.getRoot().getAbsolutePath(), cfNames, cfHandles); in columnFamilyOptions_setCompactionFilterFactory() argument
52 rocksDb.put(cfHandles.get(1), key1, value1); in columnFamilyOptions_setCompactionFilterFactory()
53 rocksDb.put(cfHandles.get(1), key2, value2); in columnFamilyOptions_setCompactionFilterFactory()
55 rocksDb.compactRange(cfHandles.get(1)); in columnFamilyOptions_setCompactionFilterFactory()
57 assertThat(rocksDb.get(cfHandles.get(1), key1)).isEqualTo(value1); in columnFamilyOptions_setCompactionFilterFactory()
58 final boolean exists = rocksDb.keyMayExist(cfHandles.get(1), key2, null); in columnFamilyOptions_setCompactionFilterFactory()
61 for (final ColumnFamilyHandle cfHandle : cfHandles) { in columnFamilyOptions_setCompactionFilterFactory()
DWalFilterTest.java54 final List<ColumnFamilyHandle> cfHandles = new ArrayList<>(); in walFilter() local
63 cfDescriptors, cfHandles)) { in walFilter() argument
69 batch.put(cfHandles.get(0), batchKeys[i][j], dummyString(1024)); in walFilter()
74 for (final ColumnFamilyHandle cfHandle : cfHandles) { in walFilter()
77 cfHandles.clear(); in walFilter()
93 cfDescriptors, cfHandles)) { in walFilter() argument
99 for (final ColumnFamilyHandle cfHandle : cfHandles) { in walFilter()
102 cfHandles.clear(); in walFilter()
DLoggerTest.java135 final List<ColumnFamilyHandle> cfHandles = new ArrayList<>(); in dbOptionsLogger() local
139 cfDescriptors, cfHandles)) { in dbOptionsLogger() argument
145 for (final ColumnFamilyHandle columnFamilyHandle : cfHandles) { in dbOptionsLogger()
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DBytewiseComparatorIntTest.java206 final List<ColumnFamilyHandle> cfHandles = new ArrayList<>(); in testRoundtripCf() local
213 cfDescriptors, cfHandles)) { in testRoundtripCf() argument
216 assertThat(cfHandles.size()).isEqualTo(2); in testRoundtripCf()
219 db.put(cfHandles.get(1), keys[i], "value".getBytes(UTF_8)); in testRoundtripCf()
222 for (final ColumnFamilyHandle cfHandle : cfHandles) { in testRoundtripCf()
225 cfHandles.clear(); in testRoundtripCf()
234 cfDescriptors, cfHandles); in testRoundtripCf()
235 final RocksIterator it = db.newIterator(cfHandles.get(1))) { in testRoundtripCf()
238 assertThat(cfHandles.size()).isEqualTo(2); in testRoundtripCf()
256 for (final ColumnFamilyHandle cfHandle : cfHandles) { in testRoundtripCf()
[all …]
DReverseBytewiseComparatorIntTest.java209 final List<ColumnFamilyHandle> cfHandles = new ArrayList<>(); in testRoundtripCf() local
216 cfDescriptors, cfHandles)) { in testRoundtripCf() argument
219 assertThat(cfHandles.size()).isEqualTo(2); in testRoundtripCf()
222 db.put(cfHandles.get(1), keys[i], "value".getBytes(UTF_8)); in testRoundtripCf()
225 for (final ColumnFamilyHandle cfHandle : cfHandles) { in testRoundtripCf()
228 cfHandles.clear(); in testRoundtripCf()
237 cfDescriptors, cfHandles); in testRoundtripCf()
238 final RocksIterator it = db.newIterator(cfHandles.get(1))) { in testRoundtripCf()
241 assertThat(cfHandles.size()).isEqualTo(2); in testRoundtripCf()
259 for (final ColumnFamilyHandle cfHandle : cfHandles) { in testRoundtripCf()
[all …]
DIntComparatorTest.java205 final List<ColumnFamilyHandle> cfHandles = new ArrayList<>(); in testRoundtripCf() local
212 cfDescriptors, cfHandles)) { in testRoundtripCf() argument
215 assertThat(cfHandles.size()).isEqualTo(2); in testRoundtripCf()
218 db.put(cfHandles.get(1), keys[i], "value".getBytes(UTF_8)); in testRoundtripCf()
221 for (final ColumnFamilyHandle cfHandle : cfHandles) { in testRoundtripCf()
224 cfHandles.clear(); in testRoundtripCf()
233 cfDescriptors, cfHandles); in testRoundtripCf()
234 final RocksIterator it = db.newIterator(cfHandles.get(1))) { in testRoundtripCf()
237 assertThat(cfHandles.size()).isEqualTo(2); in testRoundtripCf()
255 for (final ColumnFamilyHandle cfHandle : cfHandles) { in testRoundtripCf()
[all …]
/rocksdb-6.9/java/jmh/src/main/java/org/rocksdb/jmh/
DGetBenchmarks.java40 ColumnFamilyHandle[] cfHandles; field in GetBenchmarks
74 cfHandles = cfHandlesList.toArray(new ColumnFamilyHandle[0]); in setup()
79 db.put(cfHandles[i], ba("key" + j), ba("value" + j)); in setup()
91 for (final ColumnFamilyHandle cfHandle : cfHandles) { in cleanup()
101 return cfHandles[0]; in getColumnFamily()
103 return cfHandles[1]; in getColumnFamily()
110 return cfHandles[idx]; in getColumnFamily()
DMultiGetBenchmarks.java49 ColumnFamilyHandle[] cfHandles; field in MultiGetBenchmarks
83 cfHandles = cfHandlesList.toArray(new ColumnFamilyHandle[0]); in setup()
88 db.put(cfHandles[i], ba("key" + j), ba("value" + j)); in setup()
100 for (final ColumnFamilyHandle cfHandle : cfHandles) { in cleanup()
110 return cfHandles[0]; in getColumnFamily()
112 return cfHandles[1]; in getColumnFamily()
119 return cfHandles[idx]; in getColumnFamily()
DPutBenchmarks.java37 ColumnFamilyHandle[] cfHandles; field in PutBenchmarks
70 cfHandles = cfHandlesList.toArray(new ColumnFamilyHandle[0]); in setup()
75 for (final ColumnFamilyHandle cfHandle : cfHandles) { in cleanup()
85 return cfHandles[0]; in getColumnFamily()
87 return cfHandles[1]; in getColumnFamily()
94 return cfHandles[idx]; in getColumnFamily()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DRocksDB.java533 new ArrayList<>(cfHandles.length); in createColumnFamilies()
534 for (int i = 0; i < cfHandles.length; i++) { in createColumnFamilies()
564 new ArrayList<>(cfHandles.length); in createColumnFamilies()
565 for (int i = 0; i < cfHandles.length; i++) { in createColumnFamilies()
595 cfHandles[i] = columnFamilies.get(i).nativeHandle_; in dropColumnFamilies()
597 dropColumnFamilies(nativeHandle_, cfHandles); in dropColumnFamilies()
2090 keyLengths, cfHandles); in multiGet()
2190 keysArray, keyOffsets, keyLengths, cfHandles); in multiGet()
2273 keyLengths, cfHandles)); in multiGetAsList()
2346 keysArray, keyOffsets, keyLengths, cfHandles)); in multiGetAsList()
[all …]
DTransaction.java352 final long[] cfHandles = new long[columnFamilyHandles.size()]; in multiGet() local
354 cfHandles[i] = columnFamilyHandles.get(i).nativeHandle_; in multiGet()
358 keys, cfHandles); in multiGet()
557 final long[] cfHandles = new long[columnFamilyHandles.size()]; in multiGetForUpdate() local
559 cfHandles[i] = columnFamilyHandles.get(i).nativeHandle_; in multiGetForUpdate()
562 keys, cfHandles); in multiGetForUpdate()