| /rocksdb-6.9/table/ |
| D | iter_heap.h | 19 : comparator_(comparator) {} in MaxIteratorComparator()
22 return comparator_->Compare(a->key(), b->key()) < 0; in operator()
25 const InternalKeyComparator* comparator_;
33 : comparator_(comparator) {} in MinIteratorComparator()
36 return comparator_->Compare(a->key(), b->key()) > 0; in operator()
39 const InternalKeyComparator* comparator_;
|
| D | merging_iterator.cc | 43 comparator_(comparator), in MergingIterator()
46 minHeap_(comparator_), in MergingIterator()
284 const InternalKeyComparator* comparator_; member in ROCKSDB_NAMESPACE::MergingIterator
359 if (child.Valid() && comparator_->Equal(target, child.key())) { in SwitchToForward()
377 if (child.Valid() && comparator_->Equal(target, child.key())) { in SwitchToBackward()
404 maxHeap_.reset(new MergerMaxIterHeap(comparator_)); in InitMaxHeap()
|
| D | table_test.cc | 218 comparator_(cmp), in BlockConstructor()
243 return block_->NewDataIterator(comparator_, comparator_, in NewIterator()
248 const Comparator* comparator_; member in ROCKSDB_NAMESPACE::BlockConstructor
536 comparator_(cmp) { in DBConstructor()
570 options.comparator = comparator_; in NewDB()
581 const Comparator* comparator_; member in ROCKSDB_NAMESPACE::DBConstructor
|
| /rocksdb-6.9/table/block_based/ |
| D | index_builder.h | 53 : comparator_(comparator) {} in IndexBuilder()
107 const InternalKeyComparator* comparator_;
155 comparator_->FindShortestSeparator(last_key_in_current_block, in AddIndexEntry()
159 comparator_->user_comparator()->Compare( in AddIndexEntry()
167 comparator_->FindShortSuccessor(last_key_in_current_block); in AddIndexEntry()
|
| D | block.h | 240 comparator_ = comparator; in InitializeBase()
304 const Comparator* comparator_;
476 return comparator_->Compare(ikey.GetInternalKey(), b); in Compare()
612 return comparator_->Compare(a, b); in Compare()
616 return comparator_->Compare(ikey.GetKey(), b); in Compare()
|
| D | block.cc | 247 comparator_); in Seek()
402 comparator_); in Seek()
405 comparator_); in Seek()
426 comparator_); in SeekForPrev()
|
| D | index_builder.cc | 104 comparator_, table_opt_.index_block_restart_interval, in MakeNewSubIndexBuilder()
|
| /rocksdb-6.9/db/ |
| D | memtable.cc | 68 : comparator_(cmp), in MemTable()
81 comparator_, &arena_, mutable_cf_options.prefix_extractor.get(), in MemTable()
84 comparator_, &arena_, nullptr /* transform */, ioptions.info_log, in MemTable()
284 comparator_(mem.comparator_), in MemTableIterator()
362 while (Valid() && comparator_.comparator.Compare(k, key()) < 0) { in SeekForPrev()
411 const MemTable::KeyComparator comparator_; member in ROCKSDB_NAMESPACE::MemTableIterator
439 comparator_.comparator); in NewRangeTombstoneIterator()
442 fragmented_tombstone_list, comparator_.comparator, read_seq); in NewRangeTombstoneIterator()
962 if (comparator_.comparator.user_comparator()->Equal( in Update()
1021 if (comparator_.comparator.user_comparator()->Equal( in UpdateCallback()
[all …]
|
| D | forward_iterator.h | 33 comparator_(comparator) {} in MinIterComparator()
36 return comparator_->Compare(a->key(), b->key()) > 0; in operator()
39 const Comparator* comparator_;
|
| D | version_edit.cc | 138 comparator_.clear(); in Clear()
172 PutLengthPrefixedSlice(dst, comparator_); in EncodeTo()
447 comparator_ = str.ToString(); in DecodeFrom()
687 r.append(comparator_); in DebugString()
781 jw << "Comparator" << comparator_; in DebugJSON()
|
| D | version_edit.h | 264 comparator_ = name.ToString(); in SetComparatorName()
267 const std::string& GetComparatorName() const { return comparator_; } in GetComparatorName()
440 std::string comparator_; variable
|
| D | memtable.h | 412 return comparator_.comparator; in GetInternalKeyComparator()
455 KeyComparator comparator_; variable
|
| D | version_edit_handler.cc | 440 edit.comparator_ != cfd->user_comparator()->Name()) { in ExtractInfoFromVersionEdit()
443 "does not match existing comparator " + edit.comparator_); in ExtractInfoFromVersionEdit()
|
| D | version_set.cc | 4307 from_edit.comparator_ != cfd->user_comparator()->Name()) { in ExtractInfoFromVersionEdit()
4310 "does not match existing comparator " + from_edit.comparator_); in ExtractInfoFromVersionEdit()
5027 comparators.insert({edit.column_family_, edit.comparator_}); in DumpManifest()
|
| /rocksdb-6.9/utilities/write_batch_with_index/ |
| D | write_batch_with_index.cc | 44 comparator_(comparator), in BaseDeltaIterator()
109 if (comparator_->Equal(delta_iterator_->Entry().key, in Next()
145 if (comparator_->Equal(delta_iterator_->Entry().key, in Prev()
207 int compare = comparator_->Compare(delta_iterator_->Entry().key, in AssertInvariants()
286 if (comparator_->Compare(delta_entry.key, *iterate_upper_bound_) >= in UpdateCurrent()
306 comparator_->Compare(delta_entry.key, base_iterator_->key()); in UpdateCurrent()
338 const Comparator* comparator_; // not owned member in ROCKSDB_NAMESPACE::BaseDeltaIterator
|
| D | write_batch_with_index_test.cc | 31 comparator_(comparator) {} in ColumnFamilyHandleImplDummy()
33 const Comparator* GetComparator() const override { return comparator_; } in GetComparator()
37 const Comparator* comparator_; member in ROCKSDB_NAMESPACE::__anon1b97f2c50111::ColumnFamilyHandleImplDummy
|
| /rocksdb-6.9/java/src/main/java/org/rocksdb/ |
| D | ColumnFamilyOptions.java | 48 this.comparator_ = other.comparator_; in ColumnFamilyOptions()
177 comparator_ = comparator; in setComparator()
992 private AbstractComparator comparator_; field in ColumnFamilyOptions
|
| D | Options.java | 70 this.comparator_ = other.comparator_; in Options()
200 comparator_ = comparator; in setComparator()
2172 private AbstractComparator comparator_; field in Options
|