bahman/scylla
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

partiton_version: prepare partition_snapshot::squashed() for multi-schema snapshots

Browse Source 
When in upcoming patches we allow multiple schema versions within a single
snapshot, reads will have to upgrade rows on the fly.
This also applies to squashed()
This commit is contained in:
Michał Chojnowski
2023-02-28 00:30:17 +01:00
parent a2e3cf7463
commit f4e853b32d
1 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
mutation/partition_version.cc
View File

@@ -144,15 +144,16 @@ tombstone partition_snapshot::partition_tombstone() const {
}
mutation_partition partition_snapshot::squashed() const {
return ::squashed<mutation_partition>(version(),
[this] (const mutation_partition_v2& mp) -> mutation_partition {
return mp.as_mutation_partition(*schema());
},
[] (mutation_partition&& mp) { return std::move(mp); },
[this] (mutation_partition& a, const mutation_partition& b) {
mutation_application_stats app_stats;
a.apply(*schema(), b, *schema(), app_stats);
});
const partition_version* this_v = &*version();
mutation_partition mp(*this_v->get_schema());
for (auto it = this_v->last();; it = it->prev()) {
mutation_application_stats app_stats;
mp.apply(*this_v->get_schema(), it->partition().as_mutation_partition(*it->get_schema()), *it->get_schema(), app_stats);
if (it == this_v) {
break;
}
}
return mp;
}
tombstone partition_entry::partition_tombstone() const {