Searched refs:range_del_agg_ (Results 1 – 6 of 6) sorted by relevance
| /rocksdb-6.9/db/ |
| D | db_iter.cc | 71 range_del_agg_(&cf_options.internal_comparator, s), in DBIter()
313 if (range_del_agg_.ShouldDelete( in FindNextUserEntryInternal()
344 if (range_del_agg_.ShouldDelete( in FindNextUserEntryInternal()
479 range_del_agg_.ShouldDelete( in MergeValuesNewToOld()
761 if (range_del_agg_.ShouldDelete( in FindValueForCurrentKey()
779 if (range_del_agg_.ShouldDelete( in FindValueForCurrentKey()
921 range_del_agg_.ShouldDelete( in FindValueForCurrentKeyUsingSeek()
967 range_del_agg_.ShouldDelete( in FindValueForCurrentKeyUsingSeek()
1173 range_del_agg_.InvalidateRangeDelMapPositions(); in Seek()
1239 range_del_agg_.InvalidateRangeDelMapPositions(); in SeekForPrev()
[all …]
|
| D | db_iter.h | 141 ReadRangeDelAggregator* GetRangeDelAggregator() { return &range_del_agg_; } in GetRangeDelAggregator()
326 ReadRangeDelAggregator range_del_agg_; variable
|
| D | version_set.cc | 878 range_del_agg_(range_del_agg), in LevelIterator()
979 range_del_agg_, prefix_extractor_, in NewFileIterator()
1018 RangeDelAggregator* range_del_agg_; member in ROCKSDB_NAMESPACE::__anonc84eced60311::LevelIterator
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_iterator.cc | 76 range_del_agg_(range_del_agg), in CompactionIterator()
576 Status s = merge_helper_->MergeUntil(input_, range_del_agg_, in NextFromInput()
616 bool should_delete = range_del_agg_->ShouldDelete( in NextFromInput()
|
| D | compaction_iterator_test.cc | 233 range_del_agg_.reset(new CompactionRangeDelAggregator(&icmp_, snapshots_)); in InitIterators()
234 range_del_agg_->AddTombstones(std::move(range_del_iter)); in InitIterators()
258 range_del_agg_.get(), std::move(compaction), filter, &shutting_down_)); in InitIterators()
302 std::unique_ptr<CompactionRangeDelAggregator> range_del_agg_; member in ROCKSDB_NAMESPACE::CompactionIteratorTest
|
| D | compaction_iterator.h | 164 CompactionRangeDelAggregator* range_del_agg_; variable
|