Home
last modified time | relevance | path

Searched refs:readOptions (Results 1 – 23 of 23) sorted by relevance

/rocksdb-6.9/java/src/test/java/org/rocksdb/
DAbstractTransactionTest.java137 assertThat(txn2.get(readOptions, k1)).isNull(); in rollback()
168 assertThat(txn.get(readOptions, k2)).isNull(); in savePoint()
175 assertThat(txn2.get(readOptions, k2)).isNull(); in savePoint()
201 assertThat(txn.get(readOptions, k1)).isNull(); in getPut()
203 assertThat(txn.get(readOptions, k1)).isEqualTo(v1); in getPut()
417 assertThat(txn.get(readOptions, k1)).isNull(); in delete()
441 assertThat(txn.get(testCf, readOptions, key)) in delete_parts_cf()
467 assertThat(txn.get(readOptions, key)).isNull(); in delete_parts()
492 assertThat(txn.get(readOptions, k1)).isNull(); in getPutUntracked()
593 assertThat(txn.get(readOptions, k1)).isNull(); in deleteUntracked()
[all …]
DReadOptionsTest.java218 readOptions.verifyChecksums(); in failVerifyChecksumUninitialized()
226 readOptions.setFillCache(true); in failSetFillCacheUninitialized()
234 readOptions.fillCache(); in failFillCacheUninitialized()
242 readOptions.setTailing(true); in failSetTailingUninitialized()
250 readOptions.tailing(); in failTailingUninitialized()
258 readOptions.setSnapshot(null); in failSetSnapshotUninitialized()
266 readOptions.snapshot(); in failSnapshotUninitialized()
282 readOptions.iterateUpperBound(); in failIterateUpperBoundUninitialized()
298 readOptions.iterateLowerBound(); in failIterateLowerBoundUninitialized()
305 readOptions.close(); in setupUninitializedReadOptions()
[all …]
DOptimisticTransactionTest.java26 final ReadOptions readOptions = new ReadOptions()) { in getForUpdate_cf_conflict()
64 final ReadOptions readOptions = new ReadOptions()) { in getForUpdate_conflict()
68 assertThat(txn.get(readOptions, k1)).isEqualTo(v1); in getForUpdate_conflict()
78 assertThat(txn2.get(readOptions, k1)).isEqualTo(v12); in getForUpdate_conflict()
106 final ReadOptions readOptions = new ReadOptions()) { in multiGetForUpdate_cf_conflict()
124 assertThat(txn2.get(testCf, readOptions, keys[0])) in multiGetForUpdate_cf_conflict()
153 final ReadOptions readOptions = new ReadOptions()) { in multiGetForUpdate_conflict()
168 assertThat(txn2.get(readOptions, keys[0])) in multiGetForUpdate_conflict()
192 final ReadOptions readOptions = new ReadOptions()) { in undoGetForUpdate_cf_conflict()
227 final ReadOptions readOptions = new ReadOptions()) { in undoGetForUpdate_conflict()
[all …]
DSnapshotTest.java35 readOptions.setSnapshot(snapshot); in snapshots()
42 assertThat(new String(db.get(readOptions, in snapshots()
55 readOptions.setSnapshot(sameSnapshot); in snapshots()
58 assertThat(new String(db.get(readOptions, in snapshots()
64 assertThat(new String(db.get(readOptions, in snapshots()
72 readOptions.setSnapshot(null); in snapshots()
73 assertThat(new String(db.get(readOptions, in snapshots()
93 final ReadOptions readOptions = in iteratorWithSnapshot()
111 db.newIterator(readOptions)) { in iteratorWithSnapshot()
137 final ReadOptions readOptions = new ReadOptions() in iteratorWithSnapshotOnColumnFamily()
[all …]
DWriteBatchWithIndexTest.java279 final ReadOptions readOptions = new ReadOptions()) { in savePoints()
284 assertThat(getFromWriteBatchWithIndex(db, readOptions, wbwi, "k1")) in savePoints()
286 assertThat(getFromWriteBatchWithIndex(db, readOptions, wbwi, "k2")) in savePoints()
288 assertThat(getFromWriteBatchWithIndex(db, readOptions, wbwi, "k3")) in savePoints()
297 assertThat(getFromWriteBatchWithIndex(db, readOptions, wbwi, "k2")) in savePoints()
299 assertThat(getFromWriteBatchWithIndex(db, readOptions, wbwi, "k3")) in savePoints()
308 assertThat(getFromWriteBatchWithIndex(db, readOptions, wbwi, "k3")) in savePoints()
451 final ReadOptions readOptions, final WriteBatchWithIndex wbwi, in getFromWriteBatchWithIndex() argument
454 try (final RocksIterator baseIterator = db.newIterator(readOptions); in getFromWriteBatchWithIndex()
516 final ReadOptions readOptions = new ReadOptions()) { in getFromBatchAndDB()
[all …]
DTransactionTest.java26 final ReadOptions readOptions = new ReadOptions()) { in getForUpdate_cf_conflict()
31 assertThat(txn.getForUpdate(readOptions, testCf, k1, true)).isEqualTo(v1); in getForUpdate_cf_conflict()
60 final ReadOptions readOptions = new ReadOptions()) { in getForUpdate_conflict()
64 assertThat(txn.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate_conflict()
70 assertThat(txn3.getForUpdate(readOptions, k1, true)).isEqualTo(v1); in getForUpdate_conflict()
98 final ReadOptions readOptions = new ReadOptions()) { in multiGetForUpdate_cf_conflict()
105 assertThat(txn.multiGet(readOptions, cfList, keys)).isEqualTo(values); in multiGetForUpdate_cf_conflict()
111 assertThat(txn3.multiGetForUpdate(readOptions, cfList, keys)) in multiGetForUpdate_cf_conflict()
140 final ReadOptions readOptions = new ReadOptions()) { in multiGetForUpdate_conflict()
144 assertThat(txn.multiGet(readOptions, keys)).isEqualTo(values); in multiGetForUpdate_conflict()
[all …]
DKeyMayExistTest.java76 try (final ReadOptions readOptions = new ReadOptions()) { in keyMayExist() argument
77 exists = db.keyMayExist(readOptions, "key".getBytes(UTF_8), holder); in keyMayExist()
82 exists = db.keyMayExist(readOptions, "key".getBytes(UTF_8), null); in keyMayExist()
85 exists = db.keyMayExist(readOptions, sliceKey, offset, len, holder); in keyMayExist()
90 exists = db.keyMayExist(readOptions, sliceKey, offset, len, null); in keyMayExist()
117 try (final ReadOptions readOptions = new ReadOptions()) { in keyMayExist() argument
118 exists = db.keyMayExist(columnFamilyHandleList.get(0), readOptions, in keyMayExist()
124 exists = db.keyMayExist(columnFamilyHandleList.get(0), readOptions, in keyMayExist()
129 exists = db.keyMayExist(columnFamilyHandleList.get(0), readOptions, in keyMayExist()
135 exists = db.keyMayExist(columnFamilyHandleList.get(0), readOptions, in keyMayExist()
DTableFilterTest.java21 public void readOptions() throws RocksDBException { in readOptions() method in TableFilterTest
45 final ReadOptions readOptions = in readOptions()
64 db.newIterator(columnFamilyHandles.get(0), readOptions)) { in readOptions() argument
74 db.newIterator(columnFamilyHandles.get(1), readOptions)) { in readOptions() argument
DBlockBasedTableConfigTest.java192 final ReadOptions readOptions = new ReadOptions(); in blockCacheCompressedIntegration()
202 db.get(readOptions, key1); in blockCacheCompressedIntegration()
203 db.get(readOptions, key2); in blockCacheCompressedIntegration()
204 db.get(readOptions, key3); in blockCacheCompressedIntegration()
205 db.get(readOptions, key4); in blockCacheCompressedIntegration()
DSstFileReaderTest.java116 final ReadOptions readOptions = new ReadOptions(); in readSstFile() local
117 final SstFileReaderIterator iterator = reader.newIterator(readOptions); in readSstFile()
DTransactionDBTest.java130 final ReadOptions readOptions = new ReadOptions()) { in lockStatusData()
138 assertThat(txn.getForUpdate(readOptions, key, true)).isEqualTo(value); in lockStatusData()
/rocksdb-6.9/java/samples/src/main/java/
DOptimisticTransactionSample.java32 readCommitted(txnDb, writeOptions, readOptions); in main()
41 repeatableRead(txnDb, writeOptions, readOptions); in main()
70 byte[] value = txn.get(readOptions, key1); in readCommitted()
77 value = txnDb.get(readOptions, key1); in readCommitted()
112 readOptions.setSnapshot(snapshot); in repeatableRead()
129 readOptions.setSnapshot(null); in repeatableRead()
157 readOptions.setSnapshot(snapshot); in readCommitted_monotonicAtomicViews()
158 byte[] value = txn.get(readOptions, keyX); in readCommitted_monotonicAtomicViews()
167 readOptions.setSnapshot(snapshot); in readCommitted_monotonicAtomicViews()
172 value = txn.getForUpdate(readOptions, keyY, true); in readCommitted_monotonicAtomicViews()
[all …]
DTransactionSample.java33 readCommitted(txnDb, writeOptions, readOptions); in main()
42 repeatableRead(txnDb, writeOptions, readOptions); in main()
71 byte[] value = txn.get(readOptions, key1); in readCommitted()
78 value = txnDb.get(readOptions, key1); in readCommitted()
114 readOptions.setSnapshot(snapshot); in repeatableRead()
126 readOptions.setSnapshot(null); in repeatableRead()
154 readOptions.setSnapshot(snapshot); in readCommitted_monotonicAtomicViews()
155 byte[] value = txn.get(readOptions, keyX); in readCommitted_monotonicAtomicViews()
165 readOptions.setSnapshot(snapshot); in readCommitted_monotonicAtomicViews()
170 value = txn.getForUpdate(readOptions, keyY, true); in readCommitted_monotonicAtomicViews()
[all …]
DRocksDBSample.java32 final ReadOptions readOptions = new ReadOptions() in main()
173 value = db.get(readOptions, "world".getBytes()); in main()
184 testResult = db.get(readOptions, testKey); in main()
199 len = db.get(readOptions, testKey, insufficientArray); in main()
201 len = db.get(readOptions, "asdfjkl;".getBytes(), enoughArray); in main()
203 len = db.get(readOptions, testKey, enoughArray); in main()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DTransaction.java339 public byte[][] multiGet(final ReadOptions readOptions, in multiGet() argument
357 return multiGet(nativeHandle_, readOptions.nativeHandle_, in multiGet()
386 public byte[][] multiGet(final ReadOptions readOptions, in multiGet() argument
393 return multiGet(nativeHandle_, readOptions.nativeHandle_, in multiGet()
444 public byte[] getForUpdate(final ReadOptions readOptions, in getForUpdate() argument
470 public byte[] getForUpdate(final ReadOptions readOptions, in getForUpdate() argument
544 public byte[][] multiGetForUpdate(final ReadOptions readOptions, in multiGetForUpdate() argument
577 public byte[][] multiGetForUpdate(final ReadOptions readOptions, in multiGetForUpdate() argument
585 readOptions.nativeHandle_, keys); in multiGetForUpdate()
610 readOptions.nativeHandle_)); in getIterator()
[all …]
DRocksDB.java2482 final ReadOptions readOptions, final byte[] key, in keyMayExist() argument
2484 return keyMayExist(readOptions, key, 0, key.length, in keyMayExist()
2513 final ReadOptions readOptions, in keyMayExist() argument
2516 return keyMayExist(null, readOptions, in keyMayExist()
2543 final ReadOptions readOptions, final byte[] key, in keyMayExist() argument
2576 final ReadOptions readOptions, in keyMayExist() argument
2583 readOptions == null ? 0 : readOptions.nativeHandle_, in keyMayExist()
2589 readOptions == null ? 0 : readOptions.nativeHandle_, in keyMayExist()
2635 readOptions.nativeHandle_)); in newIterator()
2674 final ReadOptions readOptions) { in newIterator() argument
[all …]
DSstFileReader.java33 public SstFileReaderIterator newIterator(final ReadOptions readOptions) { in newIterator() argument
35 long iter = newIterator(nativeHandle_, readOptions.nativeHandle_); in newIterator()
/rocksdb-6.9/table/
Dtable_reader.h98 virtual Status Get(const ReadOptions& readOptions, const Slice& key,
103 virtual void MultiGet(const ReadOptions& readOptions,
108 *iter->s = Get(readOptions, iter->ikey, iter->get_context,
Dmock_table.h49 Status Get(const ReadOptions& readOptions, const Slice& key,
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DBytewiseComparatorTest.java258 try (final ReadOptions readOptions = new ReadOptions(); in doRandomIterationTest() argument
259 final RocksIterator iter = db.newIterator(readOptions)) { in doRandomIterationTest()
317 final byte[] result = db.get(readOptions, bytes(key)); in doRandomIterationTest()
/rocksdb-6.9/table/block_based/
Dblock_based_table_reader.h125 Status Get(const ReadOptions& readOptions, const Slice& key,
129 void MultiGet(const ReadOptions& readOptions,
172 Status VerifyChecksum(const ReadOptions& readOptions,
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader.h44 Status Get(const ReadOptions& readOptions, const Slice& key,
/rocksdb-6.9/table/plain/
Dplain_table_reader.h91 Status Get(const ReadOptions& readOptions, const Slice& key,