| /rocksdb-6.9/java/src/test/java/org/rocksdb/ |
| D | RocksIteratorTest.java | 35 iterator.seekToFirst(); in rocksIterator()
72 iterator.next(); in rocksIterator()
76 iterator.next(); in rocksIterator()
78 iterator.seekToLast(); in rocksIterator()
79 iterator.prev(); in rocksIterator()
83 iterator.seekToFirst(); in rocksIterator()
84 iterator.seekToLast(); in rocksIterator()
88 iterator.status(); in rocksIterator()
93 iterator.seek(key); in rocksIterator()
167 iterator.seekToFirst(); in rocksIteratorReleaseAfterCfClose()
[all …]
|
| D | SnapshotTest.java | 99 iterator.seekToFirst(); in iteratorWithSnapshot()
100 assertThat(iterator.isValid()).isTrue(); in iteratorWithSnapshot()
102 iterator.next(); in iteratorWithSnapshot()
103 assertThat(iterator.isValid()).isTrue(); in iteratorWithSnapshot()
105 iterator.next(); in iteratorWithSnapshot()
106 assertThat(iterator.isValid()).isFalse(); in iteratorWithSnapshot()
144 iterator.seekToFirst(); in iteratorWithSnapshotOnColumnFamily()
145 assertThat(iterator.isValid()).isTrue(); in iteratorWithSnapshotOnColumnFamily()
147 iterator.next(); in iteratorWithSnapshotOnColumnFamily()
148 assertThat(iterator.isValid()).isTrue(); in iteratorWithSnapshotOnColumnFamily()
[all …]
|
| D | TableFilterTest.java | 63 try (final RocksIterator iterator = in readOptions() argument
65 iterator.seekToFirst(); in readOptions()
66 while (iterator.isValid()) { in readOptions()
67 iterator.key(); in readOptions()
68 iterator.value(); in readOptions()
69 iterator.next(); in readOptions()
75 iterator.seekToFirst(); in readOptions()
76 while (iterator.isValid()) { in readOptions()
77 iterator.key(); in readOptions()
78 iterator.value(); in readOptions()
[all …]
|
| D | SstFileReaderTest.java | 117 final SstFileReaderIterator iterator = reader.newIterator(readOptions); in readSstFile() local
120 iterator.seekToFirst(); in readSstFile()
129 assertThat(iterator.key()).isEqualTo("key1".getBytes()); in readSstFile()
130 assertThat(iterator.value()).isEqualTo("value1".getBytes()); in readSstFile()
134 iterator.seek(direct); in readSstFile()
138 assertThat(iterator.isValid()).isTrue(); in readSstFile()
139 assertThat(iterator.key()).isEqualTo("key1".getBytes()); in readSstFile()
140 assertThat(iterator.value()).isEqualTo("value1".getBytes()); in readSstFile()
143 assertThat(iterator.key(direct)).isEqualTo("key1".getBytes().length); in readSstFile()
149 assertThat(iterator.value(direct)).isEqualTo("value1".getBytes().length); in readSstFile()
|
| D | RocksMemEnvTest.java | 53 try (final RocksIterator iterator = db.newIterator()) { in memEnvFillAndReopen() argument
54 iterator.seekToFirst(); in memEnvFillAndReopen()
56 assertThat(iterator.isValid()).isTrue(); in memEnvFillAndReopen()
57 assertThat(iterator.key()).isEqualTo(keys[i]); in memEnvFillAndReopen()
58 assertThat(iterator.value()).isEqualTo(values[i]); in memEnvFillAndReopen()
59 iterator.next(); in memEnvFillAndReopen()
62 assertThat(iterator.isValid()).isFalse(); in memEnvFillAndReopen()
|
| D | AbstractTransactionTest.java | 334 try(final RocksIterator iterator = txn.getIterator(readOptions)) { in getIterator() argument
335 iterator.seek(k1); in getIterator()
336 assertThat(iterator.isValid()).isTrue(); in getIterator()
337 assertThat(iterator.key()).isEqualTo(k1); in getIterator()
338 assertThat(iterator.value()).isEqualTo(v1); in getIterator()
355 try(final RocksIterator iterator = txn.getIterator(readOptions, testCf)) { in getIterator_cf() argument
356 iterator.seek(k1); in getIterator_cf()
357 assertThat(iterator.isValid()).isTrue(); in getIterator_cf()
358 assertThat(iterator.key()).isEqualTo(k1); in getIterator_cf()
359 assertThat(iterator.value()).isEqualTo(v1); in getIterator_cf()
|
| D | WriteBatchWithIndexTest.java | 159 public void iterator() throws RocksDBException { in iterator() method in WriteBatchWithIndexTest
455 final RocksIterator iterator = wbwi.newIteratorWithBase(baseIterator)) { in getFromWriteBatchWithIndex()
456 iterator.seek(key); in getFromWriteBatchWithIndex()
460 return iterator.isValid() && in getFromWriteBatchWithIndex()
461 Arrays.equals(key, iterator.key()) ? in getFromWriteBatchWithIndex()
462 new String(iterator.value()) : null; in getFromWriteBatchWithIndex()
|
| /rocksdb-6.9/db/blob/ |
| D | db_blob_index_test.cc | 288 extra_check(iterator); in TEST_F()
290 delete iterator; in TEST_F()
293 iterator = create_iterator(); in TEST_F()
297 iterator->Next(); in TEST_F()
300 extra_check(iterator); in TEST_F()
302 delete iterator; in TEST_F()
310 extra_check(iterator); in TEST_F()
312 delete iterator; in TEST_F()
318 iterator->Prev(); in TEST_F()
321 extra_check(iterator); in TEST_F()
[all …]
|
| /rocksdb-6.9/java/samples/src/main/java/ |
| D | RocksDBSample.java | 248 for (iterator.seekToFirst(); iterator.isValid(); iterator.next()) { in main()
249 iterator.status(); in main()
250 assert (iterator.key() != null); in main()
259 for (iterator.seekToLast(); iterator.isValid(); iterator.prev()) { in main()
260 iterator.status(); in main()
261 assert (iterator.key() != null); in main()
270 iterator.seekToFirst(); in main()
271 iterator.seek(iterator.key()); in main()
272 assert (iterator.key() != null); in main()
282 for (iterator.seekToLast(); iterator.isValid(); iterator.prev()) { in main()
[all …]
|
| /rocksdb-6.9/db/ |
| D | db_test2.cc | 4413 iterator->Seek("xa"); in TEST_F()
4422 iterator->Seek("xz"); in TEST_F()
4452 iterator->Seek("x"); in TEST_F()
4477 iterator->Seek("x"); in TEST_F()
4597 iterator->Seek("b1"); in TEST_F()
4609 iterator->Seek("b1"); in TEST_F()
4618 iterator->Seek("b1"); in TEST_F()
4628 iterator->Seek("b1"); in TEST_F()
4640 iterator->Seek("b1"); in TEST_F()
4647 iterator->Seek("b1"); in TEST_F()
[all …]
|
| D | column_family.h | 624 class iterator {
626 explicit iterator(ColumnFamilyData* cfd) in iterator() function
628 iterator& operator++() {
638 bool operator!=(const iterator& other) {
672 iterator begin() { return iterator(dummy_cfd_->next_); } in begin()
673 iterator end() { return iterator(dummy_cfd_); } in end()
|
| D | column_family_test.cc | 2323 iterator->SeekToFirst(); in TEST_P()
2335 for (; iterator->Valid(); iterator->Next()) { in TEST_P()
2339 ASSERT_OK(iterator->status()); in TEST_P()
2357 for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { in TEST_P()
2361 ASSERT_OK(iterator->status()); in TEST_P()
2390 iterator->SeekToFirst(); in TEST_P()
2396 for (; iterator->Valid(); iterator->Next()) { in TEST_P()
2397 ASSERT_OK(iterator->status()); in TEST_P()
2400 ASSERT_OK(iterator->status()); in TEST_P()
2456 for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { in TEST_P()
[all …]
|
| /rocksdb-6.9/monitoring/ |
| D | stats_history_test.cc | 231 Iterator* iterator = db_->NewIterator(ReadOptions()); in TEST_F() local
232 for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { in TEST_F()
233 ASSERT_TRUE(iterator->key() == iterator->value()); in TEST_F()
235 delete iterator; in TEST_F()
250 iterator = db_->NewIterator(ReadOptions()); in TEST_F()
251 for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { in TEST_F()
252 ASSERT_TRUE(iterator->key() == iterator->value()); in TEST_F()
254 delete iterator; in TEST_F()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2015-02-27-write-batch-with-index.markdown | 16 …ject from it and issue `db->Write()`. Additionally, users can create an iterator of a WriteBatchWi…
18 …iterator of the write batch, before checking data in RocksDB. For example, here is the we implemen…
|
| D | 2018-11-21-delete-range.markdown | 36 The most common pattern we see is scan-and-delete, i.e., advance an iterator
182 When an iterator is first created and seeked, we construct a skyline over its
185 of the L1+ levels. However, moving the iterator forwards or backwards is simply
226 This requires significantly less work on iterator creation, but since each memtable/SST has
227 its own range tombstone iterator, querying range tombstones requires key comparisons (and
228 possibly iterator increments) for several iterators (as opposed to v1, where we had a global
|
| D | 2014-05-14-lock.markdown | 45 …iterator, we used to creating iterator of every live men table and SST table within the mutex and …
|
| /rocksdb-6.9/tools/ |
| D | write_stress.cc | 189 std::unique_ptr<Iterator> iterator(db_->NewIterator(ReadOptions())); in IteratorHoldThread() local
192 for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { in IteratorHoldThread()
194 if (!iterator->status().ok()) { in IteratorHoldThread()
196 iterator->status().ToString().c_str()); in IteratorHoldThread()
|
| /rocksdb-6.9/util/ |
| D | autovector.h | 172 typedef iterator_impl<autovector, value_type> iterator;
174 typedef std::reverse_iterator<iterator> reverse_iterator;
318 iterator begin() { return iterator(this, 0); }
322 iterator end() { return iterator(this, this->size()); }
|
| /rocksdb-6.9/table/ |
| D | iterator.cc.d | 1 table/iterator.cc.d table/iterator.o: table/iterator.cc \
2 include/rocksdb/iterator.h include/rocksdb/cleanable.h \
|
| /rocksdb-6.9/tools/rdb/ |
| D | db_wrapper.cc | 233 std::unique_ptr<ROCKSDB_NAMESPACE::Iterator> iterator; in Dump() local
238 iterator.reset( in Dump()
245 iterator.reset(db_wrapper->db_->NewIterator( in Dump()
249 iterator->SeekToFirst(); in Dump()
251 while (iterator->Valid()) { in Dump()
253 printWithBackSlashes(iterator->key().ToString()); in Dump()
255 printWithBackSlashes(iterator->value().ToString()); in Dump()
257 iterator->Next(); in Dump()
|
| /rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/ |
| D | gtest.h | 3684 std::string::iterator it = str.end();
9018 typedef Element* iterator;
11589 typedef ParamIterator<T> iterator;
11599 iterator begin() const { return iterator(impl_->Begin()); }
11600 iterator end() const { return iterator(impl_->End()); }
11717 : base_(base), iterator_(iterator) {}
15799 typename ParamGenerator<T1>::iterator current1_;
15802 typename ParamGenerator<T2>::iterator current2_;
15927 typename ParamGenerator<T1>::iterator current1_;
15930 typename ParamGenerator<T2>::iterator current2_;
[all …]
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | WriteBatchWithIndex.java | 134 RocksIterator iterator = new RocksIterator(baseIterator.parent_, in newIteratorWithBase() local
139 return iterator; in newIteratorWithBase()
|
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_test_base.cc | 295 std::unique_ptr<Iterator> iterator(db->NewIterator(ropt)); in AssertSame() local
298 for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { in AssertSame()
300 if (GetIntVal(iterator->key().ToString(), &key_val)) { in AssertSame()
1489 std::unique_ptr<Iterator> iterator(db_->NewIterator(ropt)); in TestAcquireSnapshot() local
1490 for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { in TestAcquireSnapshot()
1492 if (GetIntVal(iterator->key().ToString(), &key_val)) { in TestAcquireSnapshot()
|
| /rocksdb-6.9/CMakeFiles/rocksdb.dir/table/ |
| D | iterator.cc.o.d | 1 CMakeFiles/rocksdb.dir/table/iterator.cc.o: \
2 /rdbg-bench/src/rocksdb-6.9/table/iterator.cc \
3 /rdbg-bench/src/rocksdb-6.9/include/rocksdb/iterator.h \
97 /usr/include/c++/v1/iterator /usr/include/c++/v1/__iterator/access.h \
103 /usr/include/c++/v1/__iterator/iterator.h \
|
| /rocksdb-6.9/CMakeFiles/rocksdb-shared.dir/table/ |
| D | iterator.cc.o.d | 1 CMakeFiles/rocksdb-shared.dir/table/iterator.cc.o: \
2 /rdbg-bench/src/rocksdb-6.9/table/iterator.cc \
3 /rdbg-bench/src/rocksdb-6.9/include/rocksdb/iterator.h \
97 /usr/include/c++/v1/iterator /usr/include/c++/v1/__iterator/access.h \
103 /usr/include/c++/v1/__iterator/iterator.h \
|