database: use read_row_flat() instead of read_row()

This commit is contained in:
Paweł Dziepak
2017-12-05 10:53:33 +00:00
parent 582bacbd81
commit bccca90207

View File

@@ -522,7 +522,7 @@ public:
return parallel_for_each(std::move(candidates),
[this](const sstables::shared_sstable& sstable) {
tracing::trace(_trace_state, "Reading key {} from sstable {}", _pr, seastar::value_of([&sstable] { return sstable->get_filename(); }));
return sstable->read_row(_schema, _pr.start()->value(), _slice, _pc, _resource_tracker, _fwd).then([this](auto smo) {
return streamed_mutation_from_flat_mutation_reader(sstable->read_row_flat(_schema, _pr.start()->value(), _slice, _pc, _resource_tracker, _fwd)).then([this](auto smo) {
if (smo) {
_mutations.emplace_back(std::move(*smo));
}