Home
last modified time | relevance | path

Searched refs:MergeHelper (Results 1 – 15 of 15) sorted by relevance

/rocksdb-6.9/db/
Dmerge_helper.h29 class MergeHelper {
31 MergeHelper(Env* env, const Comparator* user_comparator,
177 explicit MergeOutputIterator(const MergeHelper* merge_helper);
189 const MergeHelper* merge_helper_;
Dmerge_helper.cc22 MergeHelper::MergeHelper(Env* env, const Comparator* user_comparator, in MergeHelper() function in ROCKSDB_NAMESPACE::MergeHelper
51 Status MergeHelper::TimedFullMerge(const MergeOperator* merge_operator, in TimedFullMerge()
116 Status MergeHelper::MergeUntil(InternalIterator* iter, in MergeUntil()
370 MergeOutputIterator::MergeOutputIterator(const MergeHelper* merge_helper) in MergeOutputIterator()
389 CompactionFilter::Decision MergeHelper::FilterMerge(const Slice& user_key, in FilterMerge()
Ddb_iter.cc489 s = MergeHelper::TimedFullMerge( in MergeValuesNewToOld()
536 s = MergeHelper::TimedFullMerge(merge_operator_, saved_key_.GetUserKey(), in MergeValuesNewToOld()
820 s = MergeHelper::TimedFullMerge( in FindValueForCurrentKey()
838 s = MergeHelper::TimedFullMerge( in FindValueForCurrentKey()
972 Status s = MergeHelper::TimedFullMerge( in FindValueForCurrentKeyUsingSeek()
1004 Status s = MergeHelper::TimedFullMerge( in FindValueForCurrentKeyUsingSeek()
Dmerge_helper_test.cc29 merge_helper_.reset(new MergeHelper(env_, BytewiseComparator(), in Run()
50 std::unique_ptr<MergeHelper> merge_helper_;
Dmemtable.cc693 *(s->status) = MergeHelper::TimedFullMerge( in SaveValue()
731 *(s->status) = MergeHelper::TimedFullMerge( in SaveValue()
759 *(s->status) = MergeHelper::TimedFullMerge( in SaveValue()
Dbuilder.cc148 MergeHelper merge(env, internal_comparator.user_comparator(), in BuildTable()
Dwrite_batch.cc1721 Status merge_status = MergeHelper::TimedFullMerge( in MergeCF()
Dversion_set.cc1862 *status = MergeHelper::TimedFullMerge( in Get()
2044 *status = MergeHelper::TimedFullMerge( in MultiGet()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.h63 InternalIterator* input, const Comparator* cmp, MergeHelper* merge_helper,
78 InternalIterator* input, const Comparator* cmp, MergeHelper* merge_helper,
150 MergeHelper* merge_helper_;
Dcompaction_iterator.cc34 InternalIterator* input, const Comparator* cmp, MergeHelper* merge_helper, in CompactionIterator()
55 InternalIterator* input, const Comparator* cmp, MergeHelper* merge_helper, in CompactionIterator()
Dcompaction_iterator_test.cc248 new MergeHelper(Env::Default(), cmp_, merge_op, filter, nullptr, false, in InitIterators()
299 std::unique_ptr<MergeHelper> merge_helper_;
Dcompaction_job.cc868 MergeHelper merge( in ProcessKeyValueCompaction()
/rocksdb-6.9/table/
Dget_context.cc257 Status merge_status = MergeHelper::TimedFullMerge( in SaveValue()
297 Status merge_status = MergeHelper::TimedFullMerge( in SaveValue()
325 Status merge_status = MergeHelper::TimedFullMerge( in SaveValue()
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_internal.cc264 *s = MergeHelper::TimedFullMerge(merge_operator, key, &entry_value, in GetFromBatch()
Dwrite_batch_with_index.cc913 s = MergeHelper::TimedFullMerge(merge_operator, key, merge_data, in GetFromBatchAndDB()
1025 *key.s = MergeHelper::TimedFullMerge( in MultiGetFromBatchAndDB()