Home
last modified time | relevance | path

Searched refs:CompactionFilter (Results 1 – 25 of 43) sorted by relevance

12

/rocksdb-6.9/db/
Ddb_compaction_filter_test.cc63 class KeepFilter : public CompactionFilter {
75 class DeleteFilter : public CompactionFilter {
87 class DeleteISFilter : public CompactionFilter {
107 class SkipEvenFilter : public CompactionFilter {
129 class DelayFilter : public CompactionFilter {
145 class ConditionalFilter : public CompactionFilter {
161 class ChangeFilter : public CompactionFilter {
215 return std::unique_ptr<CompactionFilter>(nullptr); in CreateCompactionFilter()
230 return std::unique_ptr<CompactionFilter>(nullptr); in CreateCompactionFilter()
272 return std::unique_ptr<CompactionFilter>( in CreateCompactionFilter()
[all …]
Dmerge_helper.cc24 const CompactionFilter* compaction_filter, in MergeHelper()
250 CompactionFilter::Decision filter = in MergeUntil()
252 ? CompactionFilter::Decision::kKeep in MergeUntil()
254 if (filter != CompactionFilter::Decision::kRemoveAndSkipUntil && in MergeUntil()
258 filter = CompactionFilter::Decision::kRemove; in MergeUntil()
260 if (filter == CompactionFilter::Decision::kKeep || in MergeUntil()
261 filter == CompactionFilter::Decision::kChangeValue) { in MergeUntil()
273 if (filter == CompactionFilter::Decision::kKeep) { in MergeUntil()
392 return CompactionFilter::Decision::kKeep; in FilterMerge()
402 if (ret == CompactionFilter::Decision::kRemoveAndSkipUntil) { in FilterMerge()
[all …]
Dmerge_helper.h33 const CompactionFilter* compaction_filter, Logger* logger,
89 CompactionFilter::Decision FilterMerge(const Slice& user_key,
142 const CompactionFilter* compaction_filter_;
Dmanual_compaction_test.cc48 class DestroyAllCompactionFilter : public CompactionFilter {
61 class LogCompactionFilter : public CompactionFilter {
Ddb_universal_compaction_test.cc63 class KeepFilter : public CompactionFilter {
79 std::unique_ptr<CompactionFilter> CreateCompactionFilter( in CreateCompactionFilter()
80 const CompactionFilter::Context& context) override { in CreateCompactionFilter()
85 return std::unique_ptr<CompactionFilter>(new KeepFilter()); in CreateCompactionFilter()
94 class DelayFilter : public CompactionFilter {
113 std::unique_ptr<CompactionFilter> CreateCompactionFilter( in CreateCompactionFilter()
114 const CompactionFilter::Context& /*context*/) override { in CreateCompactionFilter()
115 return std::unique_ptr<CompactionFilter>(new DelayFilter(db_test)); in CreateCompactionFilter()
/rocksdb-6.9/db/compaction/
Dcompaction_iterator.cc40 const CompactionFilter* compaction_filter, in CompactionIterator()
62 const CompactionFilter* compaction_filter, in CompactionIterator()
193 CompactionFilter::Decision filter; in InvokeFilterIfNeeded()
196 CompactionFilter::ValueType value_type = in InvokeFilterIfNeeded()
197 ikey_.type == kTypeValue ? CompactionFilter::ValueType::kValue in InvokeFilterIfNeeded()
198 : CompactionFilter::ValueType::kBlobIndex; in InvokeFilterIfNeeded()
211 if (filter == CompactionFilter::Decision::kRemoveAndSkipUntil && in InvokeFilterIfNeeded()
216 filter = CompactionFilter::Decision::kKeep; in InvokeFilterIfNeeded()
219 if (filter == CompactionFilter::Decision::kRemove) { in InvokeFilterIfNeeded()
227 } else if (filter == CompactionFilter::Decision::kChangeValue) { in InvokeFilterIfNeeded()
[all …]
Dcompaction_iterator_test.cc42 class StallingFilter : public CompactionFilter {
78 class FilterAllKeysCompactionFilter : public CompactionFilter {
223 MergeOperator* merge_op = nullptr, CompactionFilter* filter = nullptr, in InitIterators()
276 CompactionFilter* compaction_filter = nullptr, in RunTest()
377 class Filter : public CompactionFilter { in TEST_P()
559 class Filter : public CompactionFilter { in TEST_P()
921 std::unique_ptr<CompactionFilter> compaction_filter( in TEST_F()
934 std::unique_ptr<CompactionFilter> compaction_filter( in TEST_F()
949 std::unique_ptr<CompactionFilter> compaction_filter( in TEST_F()
960 std::unique_ptr<CompactionFilter> compaction_filter( in TEST_F()
Dcompaction_iterator.h70 const CompactionFilter* compaction_filter = nullptr,
85 const CompactionFilter* compaction_filter = nullptr,
166 const CompactionFilter* compaction_filter_;
Dcompaction.h66 class CompactionFilter; variable
256 std::unique_ptr<CompactionFilter> CreateCompactionFilter() const;
/rocksdb-6.9/utilities/blob_db/
Dblob_compaction_filter.cc16 CompactionFilter::Decision BlobIndexCompactionFilterBase::FilterV2( in FilterV2()
83 CompactionFilter::BlobDecision BlobIndexCompactionFilterGC::PrepareBlobOutput( in PrepareBlobOutput()
284 std::unique_ptr<CompactionFilter>
286 const CompactionFilter::Context& /*context*/) { in CreateCompactionFilter()
301 return std::unique_ptr<CompactionFilter>(new BlobIndexCompactionFilter( in CreateCompactionFilter()
305 std::unique_ptr<CompactionFilter>
307 const CompactionFilter::Context& /*context*/) { in CreateCompactionFilter()
323 return std::unique_ptr<CompactionFilter>(new BlobIndexCompactionFilterGC( in CreateCompactionFilter()
Dblob_compaction_filter.h34 class BlobIndexCompactionFilterBase : public CompactionFilter {
146 std::unique_ptr<CompactionFilter> CreateCompactionFilter(
147 const CompactionFilter::Context& /*context*/) override;
162 std::unique_ptr<CompactionFilter> CreateCompactionFilter(
163 const CompactionFilter::Context& /*context*/) override;
/rocksdb-6.9/java/rocksjni/
Dcompaction_filter_factory_jnicallback.cc51 std::unique_ptr<CompactionFilter> CompactionFilterFactoryJniCallback::CreateCompactionFilter( in CreateCompactionFilter()
52 const CompactionFilter::Context& context) { in CreateCompactionFilter()
69 auto* cff = reinterpret_cast<CompactionFilter*>(addr_compaction_filter); in CreateCompactionFilter()
73 return std::unique_ptr<CompactionFilter>(cff); in CreateCompactionFilter()
Dcompaction_filter_factory_jnicallback.h24 virtual std::unique_ptr<CompactionFilter> CreateCompactionFilter(
25 const CompactionFilter::Context& context);
Dcompaction_filter.cc24 auto* cf = reinterpret_cast<ROCKSDB_NAMESPACE::CompactionFilter*>(handle); in Java_org_rocksdb_AbstractCompactionFilter_disposeInternal()
/rocksdb-6.9/utilities/ttl/
Ddb_ttl_impl.h151 class TtlCompactionFilter : public CompactionFilter {
154 int32_t ttl, Env* env, const CompactionFilter* user_comp_filter,
155 std::unique_ptr<const CompactionFilter> user_comp_filter_from_factory =
198 const CompactionFilter* user_comp_filter_;
199 std::unique_ptr<const CompactionFilter> user_comp_filter_from_factory_;
209 virtual std::unique_ptr<CompactionFilter> CreateCompactionFilter( in CreateCompactionFilter()
210 const CompactionFilter::Context& context) override { in CreateCompactionFilter()
211 std::unique_ptr<const CompactionFilter> user_comp_filter_from_factory = in CreateCompactionFilter()
Dttl_test.cc304 class TestFilter : public CompactionFilter {
362 std::unique_ptr<CompactionFilter> CreateCompactionFilter( in CreateCompactionFilter()
363 const CompactionFilter::Context& /*context*/) override { in CreateCompactionFilter()
364 return std::unique_ptr<CompactionFilter>( in CreateCompactionFilter()
387 std::unique_ptr<CompactionFilter> test_comp_filter_;
566 TEST_F(TtlTest, CompactionFilter) { in TEST_F() argument
/rocksdb-6.9/include/rocksdb/
Dcompaction_filter.h35 class CompactionFilter {
63 virtual ~CompactionFilter() {} in ~CompactionFilter()
205 virtual std::unique_ptr<CompactionFilter> CreateCompactionFilter(
206 const CompactionFilter::Context& context) = 0;
Doptions.h35 class CompactionFilter; variable
169 const CompactionFilter* compaction_filter = nullptr;
/rocksdb-6.9/examples/
Doptions_file_example.cc27 class DummyCompactionFilter : public CompactionFilter {
54 std::unique_ptr<CompactionFilter> compaction_filter; in main()
/rocksdb-6.9/test_util/
Dtestutil.h493 class FilterNumber : public CompactionFilter {
736 class ChanglingCompactionFilter : public CompactionFilter {
757 CompactionFilter* RandomCompactionFilter(Random* rnd);
768 std::unique_ptr<CompactionFilter> CreateCompactionFilter( in CreateCompactionFilter()
769 const CompactionFilter::Context& /*context*/) override { in CreateCompactionFilter()
770 return std::unique_ptr<CompactionFilter>(); in CreateCompactionFilter()
/rocksdb-6.9/utilities/cassandra/
Dcassandra_functional_test.cc102 std::unique_ptr<CompactionFilter> CreateCompactionFilter( in CreateCompactionFilter()
103 const CompactionFilter::Context& /*context*/) override { in CreateCompactionFilter()
104 return std::unique_ptr<CompactionFilter>(new CassandraCompactionFilter( in CreateCompactionFilter()
Dcassandra_compaction_filter.h25 class CassandraCompactionFilter : public CompactionFilter {
Dcassandra_compaction_filter.cc18 CompactionFilter::Decision CassandraCompactionFilter::FilterV2( in FilterV2()
/rocksdb-6.9/docs/_posts/
D2016-04-26-rocksdb-4-5-1-released.markdown53 …* CompactionFilter has new member function called IgnoreSnapshots which allows CompactionFilter to…
/rocksdb-6.9/utilities/compaction_filters/
Dremove_emptyvalue_compactionfilter.h17 class RemoveEmptyValueCompactionFilter : public CompactionFilter {

12