mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

idl: Rename range_tombstone::key to start

Browse Source 
... and make it a clustering_key_prefix, in preparation of
supporting not-whole-row range tombstones.

Signed-off-by: Duarte Nunes <duarte@scylladb.com>
This commit is contained in:
Duarte Nunes
2016-04-23 21:10:12 +02:00
parent 6da0449fc7
commit e2812c1b7a
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
idl/mutation.idl.hh
View File

@@ -83,7 +83,7 @@ class deletable_row stub [[writable]] {
};
class range_tombstone stub [[writable]] {
clustering_key key;
clustering_key_prefix start;
tombstone tomb;
};
@@ -118,4 +118,4 @@ class canonical_mutation stub [[writable]] {
partition_key key;
column_mapping mapping;
mutation_partition partition;
}
}

2
mutation_partition_serializer.cc
View File

@@ -146,7 +146,7 @@ void mutation_partition_serializer::write_serialized(Writer&& writer, const sche
auto srow_writer = std::move(writer).write_tomb(mp.partition_tombstone()).start_static_row();
auto row_tombstones = write_row_cells(std::move(srow_writer), mp.static_row(), s, column_kind::static_column).end_static_row().start_range_tombstones();
for (auto&& rt : mp.row_tombstones()) {
row_tombstones.add().write_key(rt.prefix()).write_tomb(rt.t()).end_range_tombstone();
row_tombstones.add().write_start(rt.prefix()).write_tomb(rt.t()).end_range_tombstone();
}
auto clustering_rows = std::move(row_tombstones).end_range_tombstones().start_rows();
for (auto&& cr : mp.clustered_rows()) {

4
mutation_partition_view.cc
View File

@@ -173,9 +173,9 @@ mutation_partition_view::accept(const column_mapping& cm, mutation_partition_vis
read_and_visit_row(mpv.static_row(), cm, column_kind::static_column, static_row_cell_visitor{visitor});
for (auto&& rt : mpv.range_tombstones()) {
visitor.accept_row_tombstone(rt.key(), rt.tomb());
visitor.accept_row_tombstone(rt.start(), rt.tomb());
}
for (auto&& cr : mpv.rows()) {
visitor.accept_row(cr.key(), cr.deleted_at(), read_row_marker(cr.marker()));