Searched refs:merge_operator_ (Results 1 – 7 of 7) sorted by relevance
| /rocksdb-6.9/utilities/ |
| D | util_merge_operators_test.cc | 28 merge_operator_->FullMergeV2(merge_in, &merge_out); in FullMergeV2()
46 merge_operator_->FullMergeV2(merge_in, &merge_out); in FullMergeV2()
58 merge_operator_->PartialMerge(key, left, right, &result, nullptr); in PartialMerge()
67 merge_operator_->PartialMergeMulti(key, operands_slice, &result, nullptr); in PartialMergeMulti()
72 std::shared_ptr<MergeOperator> merge_operator_; member in ROCKSDB_NAMESPACE::UtilMergeOperatorTest
76 merge_operator_ = MergeOperators::CreateMaxOperator(); in TEST_F()
|
| /rocksdb-6.9/table/ |
| D | get_context.cc | 50 merge_operator_(merge_operator), in GetContext()
253 assert(merge_operator_ != nullptr); in SaveValue()
258 merge_operator_, user_key_, &value, in SaveValue()
298 merge_operator_, user_key_, nullptr, in SaveValue()
317 if (do_merge_ && merge_operator_ != nullptr && in SaveValue()
318 merge_operator_->ShouldMerge( in SaveValue()
326 merge_operator_, user_key_, nullptr, in SaveValue()
|
| D | get_context.h | 164 const MergeOperator* merge_operator_; variable
|
| /rocksdb-6.9/db/ |
| D | db_iter.cc | 47 merge_operator_(cf_options.merge_operator), in DBIter()
452 if (!merge_operator_) { in MergeValuesNewToOld()
490 merge_operator_, ikey.user_key, &val, merge_context_.GetOperands(), in MergeValuesNewToOld()
536 s = MergeHelper::TimedFullMerge(merge_operator_, saved_key_.GetUserKey(), in MergeValuesNewToOld()
786 assert(merge_operator_ != nullptr); in FindValueForCurrentKey()
821 merge_operator_, saved_key_.GetUserKey(), nullptr, in FindValueForCurrentKey()
839 merge_operator_, saved_key_.GetUserKey(), &pinned_value_, in FindValueForCurrentKey()
973 merge_operator_, saved_key_.GetUserKey(), &val, in FindValueForCurrentKeyUsingSeek()
1005 merge_operator_, saved_key_.GetUserKey(), nullptr, in FindValueForCurrentKeyUsingSeek()
|
| D | db_iter.h | 277 const MergeOperator* const merge_operator_; variable
|
| D | version_set.cc | 1715 merge_operator_((cfd_ == nullptr) ? nullptr in Version()
1758 user_comparator(), merge_operator_, info_log_, db_statistics_, in Get()
1762 merge_operator_ ? &pinned_iters_mgr : nullptr, callback, is_blob, in Get()
1766 if (merge_operator_) { in Get()
1854 if (!merge_operator_) { in Get()
1863 merge_operator_, user_key, nullptr, merge_context->GetOperands(), in Get()
1882 if (merge_operator_) { in MultiGet()
1898 user_comparator(), merge_operator_, info_log_, db_statistics_, in MultiGet()
1902 merge_operator_ ? &pinned_iters_mgr : nullptr, callback, is_blob, in MultiGet()
2034 if (!merge_operator_) { in MultiGet()
[all …]
|
| D | version_set.h | 736 const MergeOperator* merge_operator_; variable
|