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

thrift/handler: Remove leftover debug artifacts

Browse Source 
Signed-off-by: Duarte Nunes <duarte@scylladb.com>
Message-Id: <20170705161156.2307-1-duarte@scylladb.com>
This commit is contained in:
Duarte Nunes
2017-07-05 18:11:56 +02:00
committed by Avi Kivity
parent 6d0bd01e0f
commit d583ef6860
1 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
thrift/handler.cc
View File

@@ -1565,11 +1565,9 @@ private:
abort();
}
void accept_new_row(const clustering_key_prefix& key, const query::result_row_view& static_row, const query::result_row_view& row) {
std::cout << "accept new row\n";
auto it = row.iterator();
auto cell = it.next_atomic_cell();
if (cell && _current_cell_limit > 0) {
std::cout << "has normal cell?!\n";
bytes column_name = composite::serialize_value(key.components(), _s.thrift().has_compound_comparator()).release_bytes();
Aggregator::on_column(_current_aggregation, column_name, *cell);
_current_cell_limit -= 1;
@@ -1577,14 +1575,11 @@ private:
accept_partition_end(static_row);
}
void accept_new_row(const query::result_row_view& static_row, const query::result_row_view& row) {
std::cout << "accept new row static\n";
accept_partition_end(static_row);
}
void accept_partition_end(const query::result_row_view& static_row) {
std::cout << "accept row partition end\n";
auto it = static_row.iterator();
for (auto&& id : _slice.static_columns) {
std::cout << "going over the static cols\n";
auto cell = it.next_atomic_cell();
if (cell && _current_cell_limit > 0) {
Aggregator::on_column(_current_aggregation, _s.static_column_at(id).name(), *cell);