| /rocksdb-6.9/table/ |
| D | sst_file_writer.cc | 112 RangeTombstone tombstone(begin_key, end_key, 0 /* Sequence Number */); in DeleteRange() local
114 file_info.smallest_range_del_key.assign(tombstone.start_key_.data(), in DeleteRange()
115 tombstone.start_key_.size()); in DeleteRange()
116 file_info.largest_range_del_key.assign(tombstone.end_key_.data(), in DeleteRange()
117 tombstone.end_key_.size()); in DeleteRange()
120 tombstone.start_key_, file_info.smallest_range_del_key) < 0) { in DeleteRange()
121 file_info.smallest_range_del_key.assign(tombstone.start_key_.data(), in DeleteRange()
125 tombstone.end_key_, file_info.largest_range_del_key) > 0) { in DeleteRange()
126 file_info.largest_range_del_key.assign(tombstone.end_key_.data(), in DeleteRange()
127 tombstone.end_key_.size()); in DeleteRange()
[all …]
|
| /rocksdb-6.9/db/ |
| D | range_del_aggregator_bench.cc | 101 RangeTombstone tombstone; member
106 tombstone = RangeTombstone(start_key, end_key, seq); in PersistentRangeTombstone()
116 tombstone = RangeTombstone(start_key, end_key, t.tombstone.seq_); in operator =()
126 tombstone = RangeTombstone(start_key, end_key, t.tombstone.seq_); in operator =()
146 auto key_and_value = range_del.tombstone.Serialize(); in MakeRangeDelIterator()
|
| D | range_tombstone_fragmenter_test.cc | 32 void CheckIterPosition(const RangeTombstone& tombstone, in CheckIterPosition() argument
35 EXPECT_EQ(tombstone.start_key_, ExtractUserKey(iter->key())); in CheckIterPosition()
36 EXPECT_EQ(tombstone.end_key_, iter->value()); in CheckIterPosition()
37 EXPECT_EQ(tombstone.seq_, iter->seq()); in CheckIterPosition()
40 EXPECT_EQ(tombstone.start_key_, iter->start_key()); in CheckIterPosition()
41 EXPECT_EQ(tombstone.end_key_, iter->end_key()); in CheckIterPosition()
42 EXPECT_EQ(tombstone.seq_, GetInternalKeySeqno(iter->key())); in CheckIterPosition()
|
| D | range_del_aggregator_test.cc | 169 void CheckIterPosition(const RangeTombstone& tombstone, in CheckIterPosition() argument
172 EXPECT_EQ(tombstone.start_key_, ExtractUserKey(iter->key())); in CheckIterPosition()
173 EXPECT_EQ(tombstone.end_key_, iter->value()); in CheckIterPosition()
174 EXPECT_EQ(tombstone.seq_, iter->seq()); in CheckIterPosition()
177 EXPECT_EQ(tombstone.start_key_, iter->start_key()); in CheckIterPosition()
178 EXPECT_EQ(tombstone.end_key_, iter->end_key()); in CheckIterPosition()
179 EXPECT_EQ(tombstone.seq_, GetInternalKeySeqno(iter->key())); in CheckIterPosition()
|
| D | builder.cc | 178 auto tombstone = range_del_it->Tombstone(); in BuildTable() local
179 auto kv = tombstone.Serialize(); in BuildTable()
181 meta->UpdateBoundariesForRange(kv.first, tombstone.SerializeEndKey(), in BuildTable()
182 tombstone.seq_, internal_comparator); in BuildTable()
|
| D | external_sst_file_ingestion_job.cc | 501 RangeTombstone tombstone(key, range_del_iter->value()); in GetIngestedFileInfo() local
503 InternalKey start_key = tombstone.SerializeKey(); in GetIngestedFileInfo()
509 InternalKey end_key = tombstone.SerializeEndKey(); in GetIngestedFileInfo()
|
| /rocksdb-6.9/docs/_posts/ |
| D | 2018-11-21-delete-range.markdown | 74 tombstone covering a key could be anywhere, making binary search impossible.
82 also has no way to detect when a range tombstone no longer covers anything and
88 tombstone is obsolete, and seqnum zeroing can cause a key
89 to go from above a range tombstone to below, i.e., disappearing. The upside is
117 then applied to a dedicated range tombstone memtable during `Write`. Later in
118 the background the range tombstone memtable and its corresponding data memtable
119 are flushed together into a single SST with a range tombstone meta-block. SSTs
144 if we implement this, the range tombstone memtable still needs to be linearly
178 range tombstone memtables/meta-blocks.
207 easily cache many of these range tombstone fragments on the read path.
[all …]
|
| /rocksdb-6.9/utilities/cassandra/ |
| D | format.cc | 273 std::shared_ptr<Tombstone> tombstone = expiring_column->ToTombstone(); in ConvertExpiredColumnsToTombstones() local
274 new_columns.push_back(tombstone); in ConvertExpiredColumnsToTombstones()
288 std::shared_ptr<Tombstone> tombstone = in RemoveTombstones() local
291 if (tombstone->Collectable(gc_grace_period)) { in RemoveTombstones()
|
| /rocksdb-6.9/db/compaction/ |
| D | compaction_job.cc | 1207 auto tombstone = it->Tombstone(); in FinishCompactionOutputFile() local
1209 int cmp = ucmp->Compare(*upper_bound, tombstone.start_key_); in FinishCompactionOutputFile()
1222 if (bottommost_level_ && tombstone.seq_ <= earliest_snapshot) { in FinishCompactionOutputFile()
1230 auto kv = tombstone.Serialize(); in FinishCompactionOutputFile()
1257 *lower_bound, lower_bound_from_sub_compact ? tombstone.seq_ : 0, in FinishCompactionOutputFile()
1260 InternalKey largest_candidate = tombstone.SerializeEndKey(); in FinishCompactionOutputFile()
1287 tombstone.seq_, in FinishCompactionOutputFile()
|
| /rocksdb-6.9/ |
| D | HISTORY.md | 12 * Fix a bug where range tombstone blocks in ingested files were cached incorrectly during ingestion…
345 * Fix handling of corrupt range tombstone blocks such that corruptions cannot cause deleted keys to…
347 …int lookup result when querying the endpoint of a file that has been extended by a range tombstone.
371 …tombstone truncation to avoid erroneously covering newer keys at a lower level, and include range …
377 …he presence of range tombstones where merge operands covered by a range tombstone always result in…
|