Home
last modified time | relevance | path

Searched refs:prefix_extractor (Results 1 – 25 of 81) sorted by relevance

1234

/rocksdb-6.9/table/block_based/
Dfull_filter_block.cc100 if (prefix_extractor) { in FullFilterBlockReader()
205 MultiGetRange* range, const SliceTransform* prefix_extractor, in PrefixesMayMatch() argument
213 MayMatch(range, no_io, prefix_extractor, lookup_context); in PrefixesMayMatch()
246 if (!prefix_extractor) { in MayMatch()
248 } else if (prefix_extractor->InDomain(iter->ukey)) { in MayMatch()
249 prefixes.emplace_back(prefix_extractor->Transform(iter->ukey)); in MayMatch()
290 if (!prefix_extractor || !prefix_extractor->InDomain(user_key)) { in RangeMayExist()
294 Slice prefix = prefix_extractor->Transform(user_key); in RangeMayExist()
301 return PrefixMayMatch(prefix, prefix_extractor, kNotValid, no_io, in RangeMayExist()
314 if (iterate_upper_bound != nullptr && prefix_extractor) { in IsFilterCompatible()
[all …]
Dfilter_block.h100 const SliceTransform* prefix_extractor,
107 const SliceTransform* prefix_extractor, in KeysMayMatch() argument
114 if (!KeyMayMatch(ukey, prefix_extractor, block_offset, no_io, &ikey, in KeysMayMatch()
125 const SliceTransform* prefix_extractor,
132 const SliceTransform* prefix_extractor, in PrefixesMayMatch() argument
139 if (prefix_extractor->InDomain(ukey) && in PrefixesMayMatch()
140 !PrefixMayMatch(prefix_extractor->Transform(ukey), prefix_extractor, in PrefixesMayMatch()
160 const SliceTransform* prefix_extractor, in RangeMayExist() argument
170 Slice prefix = prefix_extractor->Transform(user_key); in RangeMayExist()
171 return PrefixMayMatch(prefix, prefix_extractor, kNotValid, no_io, in RangeMayExist()
Dpartitioned_filter_block_test.cc118 const SliceTransform* prefix_extractor = nullptr) { in NewBuilder() argument
128 prefix_extractor, table_options_.whole_key_filtering, in NewBuilder()
225 NewBuilder(pib.get(), prefix_extractor)); in TestBlockPerTwoKeys()
326 std::unique_ptr<const SliceTransform> prefix_extractor( in TEST_P() local
330 NewBuilder(pib.get(), prefix_extractor.get())); in TEST_P()
344 prefix_extractor->Transform(key), prefix_extractor.get(), kNotValid, in TEST_P()
354 prefix_extractor->Transform(key), prefix_extractor.get(), kNotValid, in TEST_P()
365 std::unique_ptr<const SliceTransform> prefix_extractor( in TEST_P() local
369 NewBuilder(pib.get(), prefix_extractor.get())); in TEST_P()
388 auto prefix = prefix_extractor->Transform(key); in TEST_P()
[all …]
Dfull_filter_block.h40 explicit FullFilterBlockBuilder(const SliceTransform* prefix_extractor,
63 const SliceTransform* prefix_extractor() { return prefix_extractor_; } in prefix_extractor() function
96 bool KeyMayMatch(const Slice& key, const SliceTransform* prefix_extractor,
102 const SliceTransform* prefix_extractor,
109 const SliceTransform* prefix_extractor,
114 const SliceTransform* prefix_extractor,
119 const SliceTransform* prefix_extractor,
129 const SliceTransform* prefix_extractor,
Dpartitioned_filter_block.cc59 next_key && prefix_extractor() && prefix_extractor()->InDomain(*next_key); in MaybeCutAFilterBlock()
159 const Slice& key, const SliceTransform* prefix_extractor, in KeyMayMatch() argument
168 return MayMatch(key, prefix_extractor, block_offset, no_io, const_ikey_ptr, in KeyMayMatch()
174 const Slice& prefix, const SliceTransform* prefix_extractor, in PrefixMayMatch() argument
182 if (!table_prefix_extractor() && !prefix_extractor) { in PrefixMayMatch()
186 return MayMatch(prefix, prefix_extractor, block_offset, no_io, const_ikey_ptr, in PrefixMayMatch()
249 const Slice& slice, const SliceTransform* prefix_extractor, in MayMatch() argument
280 slice, prefix_extractor, block_offset, no_io, const_ikey_ptr, get_context, in MayMatch()
Dpartitioned_filter_block.h26 const SliceTransform* prefix_extractor, bool whole_key_filtering,
79 bool KeyMayMatch(const Slice& key, const SliceTransform* prefix_extractor,
84 const SliceTransform* prefix_extractor,
102 const Slice& slice, const SliceTransform* prefix_extractor,
106 bool MayMatch(const Slice& slice, const SliceTransform* prefix_extractor,
Dblock_based_table_reader.cc207 prefix_extractor->Name()) != 0) { in PrefixExtractorChanged()
568 const SliceTransform* prefix_extractor, in Open() argument
624 if (prefix_extractor != nullptr) { in Open()
1918 const SliceTransform* prefix_extractor; in PrefixMayMatch() local
1924 prefix_extractor = options_prefix_extractor; in PrefixMayMatch()
1929 if (!prefix_extractor->InDomain(user_key)) { in PrefixMayMatch()
2035 prefix_extractor != nullptr, in NewIterator()
2043 prefix_extractor != nullptr, in NewIterator()
2082 prefix_extractor->Name()) == 0 && in FullFilterKeyMayMatch()
2100 const SliceTransform* prefix_extractor, in FullFilterKeysMayMatch() argument
[all …]
Dblock_based_filter_block.h39 BlockBasedFilterBlockBuilder(const SliceTransform* prefix_extractor,
94 bool KeyMayMatch(const Slice& key, const SliceTransform* prefix_extractor,
99 const SliceTransform* prefix_extractor,
Dblock_based_table_reader.h95 const SliceTransform* prefix_extractor = nullptr,
116 const SliceTransform* prefix_extractor,
126 GetContext* get_context, const SliceTransform* prefix_extractor,
131 const SliceTransform* prefix_extractor,
384 const SliceTransform* prefix_extractor,
391 const SliceTransform* prefix_extractor,
Dfull_filter_block_test.cc236 std::unique_ptr<const SliceTransform> prefix_extractor( in TEST_F() local
240 FullFilterBlockBuilder builder(prefix_extractor.get(), WHOLE_KEY, in TEST_F()
259 std::unique_ptr<const SliceTransform> prefix_extractor( in TEST_F() local
263 FullFilterBlockBuilder builder(prefix_extractor.get(), WHOLE_KEY, in TEST_F()
/rocksdb-6.9/utilities/options/
Doptions_util_test.cc230 cf_descs.back().options.prefix_extractor.reset( in TEST_F()
277 std::shared_ptr<const SliceTransform> prefix_extractor = in TEST_F() local
278 cf_descs[1].options.prefix_extractor; in TEST_F()
281 ASSERT_NE(prefix_extractor, nullptr); in TEST_F()
282 cf_descs[1].options.prefix_extractor.reset(); in TEST_F()
290 cf_descs[1].options.prefix_extractor = prefix_extractor; in TEST_F()
297 std::shared_ptr<const SliceTransform> prefix_extractor = in TEST_F() local
298 cf_descs[0].options.prefix_extractor; in TEST_F()
301 ASSERT_EQ(prefix_extractor, nullptr); in TEST_F()
302 cf_descs[0].options.prefix_extractor.reset(); in TEST_F()
[all …]
/rocksdb-6.9/db/
Dtable_cache.h73 const SliceTransform* prefix_extractor, TableReader** table_reader_ptr,
92 const SliceTransform* prefix_extractor = nullptr,
117 const SliceTransform* prefix_extractor = nullptr,
134 const SliceTransform* prefix_extractor = nullptr,
153 const SliceTransform* prefix_extractor = nullptr,
162 const SliceTransform* prefix_extractor = nullptr);
168 const SliceTransform* prefix_extractor = nullptr);
175 const SliceTransform* prefix_extractor = nullptr);
201 const SliceTransform* prefix_extractor = nullptr,
Dtable_cache.cc116 TableReaderOptions(ioptions_, prefix_extractor, file_options, in GetTableReader()
136 const SliceTransform* prefix_extractor, in FindTable() argument
357 const SliceTransform* prefix_extractor, in Get() argument
559 const SliceTransform* prefix_extractor, bool no_io) { in GetTableProperties() argument
571 prefix_extractor, no_io); in GetTableProperties()
585 const SliceTransform* prefix_extractor) { in GetMemoryUsageByTableReader() argument
595 prefix_extractor, true); in GetMemoryUsageByTableReader()
613 const SliceTransform* prefix_extractor) { in ApproximateOffsetOf() argument
620 prefix_extractor, false /* no_io */, in ApproximateOffsetOf()
640 const SliceTransform* prefix_extractor) { in ApproximateSize() argument
[all …]
Ddb_bloom_filter_test.cc151 options.prefix_extractor = in TEST_F()
218 options.prefix_extractor.reset(NewFixedPrefixTransform(8)); in TEST_F()
269 options.prefix_extractor.reset(NewFixedPrefixTransform(3)); in TEST_F()
309 options.prefix_extractor.reset(); in TEST_F()
329 options.prefix_extractor.reset(NewFixedPrefixTransform(3)); in TEST_F()
350 options.prefix_extractor.reset(); in TEST_F()
389 options.prefix_extractor.reset(NewFixedPrefixTransform(3)); in TEST_F()
406 options.prefix_extractor.reset(NewFixedPrefixTransform(3)); in TEST_F()
971 options.prefix_extractor.reset( in TEST_F()
1003 options.prefix_extractor.reset(); in TEST_F()
[all …]
Dplain_table_db_test.cc142 options.prefix_extractor.reset(NewFixedPrefixTransform(8)); in CurrentOptions()
275 const SliceTransform* prefix_extractor, in TestPlainTableReader() argument
281 prefix_extractor), in TestPlainTableReader()
403 options.prefix_extractor.reset(); in TEST_P()
410 options.prefix_extractor.reset(NewFixedPrefixTransform(6)); in TEST_P()
417 options.prefix_extractor.reset(NewFixedPrefixTransform(8)); in TEST_P()
424 options.prefix_extractor.reset(); in TEST_P()
468 options.prefix_extractor.reset(); in TEST_P()
578 options.prefix_extractor = nullptr; in TEST_P()
694 options.prefix_extractor = nullptr; in TEST_P()
[all …]
Dforward_iterator.cc39 const SliceTransform* prefix_extractor) in ForwardLevelIterator() argument
47 prefix_extractor_(prefix_extractor) {} in ForwardLevelIterator()
208 prefix_extractor_(current_sv->mutable_cf_options.prefix_extractor.get()), in ForwardIterator()
653 sv_->mutable_cf_options.prefix_extractor.get(), in RebuildIterators()
730 svnew->mutable_cf_options.prefix_extractor.get(), in RenewIterators()
778 sv_->mutable_cf_options.prefix_extractor.get())); in BuildLevelIterators()
794 sv_->mutable_cf_options.prefix_extractor.get(), in ResetIncompleteIterators()
/rocksdb-6.9/table/plain/
Dplain_table_builder.cc74 encoder_(encoding_type, user_key_len, moptions.prefix_extractor.get(), in PlainTableBuilder()
77 prefix_extractor_(moptions.prefix_extractor.get()) { in PlainTableBuilder()
82 &arena_, ioptions, moptions.prefix_extractor.get(), index_sparseness, in PlainTableBuilder()
100 properties_.prefix_extractor_name = moptions_.prefix_extractor != nullptr in PlainTableBuilder()
101 ? moptions_.prefix_extractor->Name() in PlainTableBuilder()
135 if (moptions_.prefix_extractor == nullptr) { in Add()
139 moptions_.prefix_extractor->Transform(internal_key.user_key); in Add()
Dplain_table_key_coding.h33 const SliceTransform* prefix_extractor, in PlainTableKeyEncoder() argument
35 : encoding_type_((prefix_extractor != nullptr) ? encoding_type : kPlain), in PlainTableKeyEncoder()
37 prefix_extractor_(prefix_extractor), in PlainTableKeyEncoder()
142 const SliceTransform* prefix_extractor) in PlainTableKeyDecoder() argument
147 prefix_extractor_(prefix_extractor), in PlainTableKeyDecoder()
Dplain_table_reader.h78 const SliceTransform* prefix_extractor = nullptr);
84 const SliceTransform* prefix_extractor,
92 GetContext* get_context, const SliceTransform* prefix_extractor,
118 const SliceTransform* prefix_extractor);
Dplain_table_reader.cc101 const SliceTransform* prefix_extractor) in PlainTableReader() argument
106 prefix_extractor_(prefix_extractor), in PlainTableReader()
125 const SliceTransform* prefix_extractor) { in Open() argument
146 if (!prefix_extractor) { in Open()
150 } else if (prefix_extractor_in_file.compare(prefix_extractor->Name()) != in Open()
168 encoding_type, file_size, props.get(), prefix_extractor)); in Open()
/rocksdb-6.9/table/
Dtable_reader.h51 const ReadOptions&, const SliceTransform* prefix_extractor, Arena* arena,
100 const SliceTransform* prefix_extractor,
105 const SliceTransform* prefix_extractor,
109 prefix_extractor, skip_filters);
Dtable_test.cc387 const SliceTransform* prefix_extractor) const override { in NewIterator()
772 options_.prefix_extractor.reset(NewNoopTransform()); in Init()
782 options_.prefix_extractor = nullptr; in Init()
1463 options.prefix_extractor.reset(NewNoopTransform()); in TEST_P()
1807 options.prefix_extractor.reset(NewNoopTransform()); in TEST_P()
1848 options.prefix_extractor.reset(NewFixedPrefixTransform(1)); in TEST_P()
1861 options.prefix_extractor.reset(NewFixedPrefixTransform(9)); in TEST_P()
2792 moptions.prefix_extractor.get()); in TEST_P()
2966 moptions4.prefix_extractor.get())); in TEST_P()
3133 c.NewIterator(moptions.prefix_extractor.get())); in TEST_P()
[all …]
Dsst_file_reader.cc55 TableReaderOptions t_opt(r->ioptions, r->moptions.prefix_extractor.get(), in Open()
71 options, r->moptions.prefix_extractor.get(), /*arena=*/nullptr, in NewIterator()
/rocksdb-6.9/options/
Dcf_options.h143 prefix_extractor(options.prefix_extractor), in MutableCFOptions()
182 prefix_extractor(nullptr), in MutableCFOptions()
231 std::shared_ptr<const SliceTransform> prefix_extractor; member
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader.h45 GetContext* get_context, const SliceTransform* prefix_extractor,
52 const SliceTransform* prefix_extractor,

1234