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

db/view/view_builder: use v2 reader

Browse Source
This commit is contained in:
Botond Dénes
2022-01-12 15:35:20 +02:00
parent bba20f5cce
commit 45b36d91c6
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
db/view/view.cc
View File

@@ -1494,7 +1494,7 @@ future<> view_builder::initialize_reader_at_current_token(build_step& step) {
return step.reader.close().then([this, &step] {
step.pslice = make_partition_slice(*step.base->schema());
step.prange = dht::partition_range(dht::ring_position::starting_at(step.current_token()), dht::ring_position::max());
step.reader = downgrade_to_v1(step.base->get_sstable_set().make_local_shard_sstable_reader(
step.reader = step.base->get_sstable_set().make_local_shard_sstable_reader(
step.base->schema(),
_permit,
step.prange,
@@ -1502,7 +1502,7 @@ future<> view_builder::initialize_reader_at_current_token(build_step& step) {
default_priority_class(),
nullptr,
streamed_mutation::forwarding::no,
mutation_reader::forwarding::no));
mutation_reader::forwarding::no);
});
}

2
db/view/view_builder.hh
View File

@@ -135,7 +135,7 @@ class view_builder final : public service::migration_listener::only_view_notific
lw_shared_ptr<replica::column_family> base;
query::partition_slice pslice;
dht::partition_range prange;
flat_mutation_reader reader{nullptr};
flat_mutation_reader_v2 reader{nullptr};
dht::decorated_key current_key{dht::minimum_token(), partition_key::make_empty()};
std::vector<view_build_status> build_status;