diff --git a/database.hh b/database.hh index 3c8064dd7a..935435f991 100644 --- a/database.hh +++ b/database.hh @@ -1046,8 +1046,8 @@ public: unsigned shard_of(const dht::token& t); unsigned shard_of(const mutation& m); unsigned shard_of(const frozen_mutation& m); - future> query(schema_ptr, const query::read_command& cmd, query::result_request request, const std::vector& ranges, tracing::trace_state_ptr trace_state = nullptr); - future query_mutations(schema_ptr, const query::read_command& cmd, const query::partition_range& range, tracing::trace_state_ptr trace_state = nullptr); + future> query(schema_ptr, const query::read_command& cmd, query::result_request request, const std::vector& ranges, tracing::trace_state_ptr trace_state); + future query_mutations(schema_ptr, const query::read_command& cmd, const query::partition_range& range, tracing::trace_state_ptr trace_state); future<> apply(schema_ptr, const frozen_mutation&); future<> apply_streaming_mutation(schema_ptr, utils::UUID plan_id, const frozen_mutation&, bool fragmented); keyspace::config make_keyspace_config(const keyspace_metadata& ksm); diff --git a/service/storage_proxy.hh b/service/storage_proxy.hh index cbae036729..4785e8a1f2 100644 --- a/service/storage_proxy.hh +++ b/service/storage_proxy.hh @@ -215,8 +215,8 @@ private: db::read_repair_decision new_read_repair_decision(const schema& s); ::shared_ptr get_read_executor(lw_shared_ptr cmd, query::partition_range pr, db::consistency_level cl, tracing::trace_state_ptr trace_state); future>> query_singular_local(schema_ptr, lw_shared_ptr cmd, const query::partition_range& pr, - query::result_request request = query::result_request::result_and_digest, - tracing::trace_state_ptr trace_state = nullptr); + query::result_request request, + tracing::trace_state_ptr trace_state); future query_singular_local_digest(schema_ptr, lw_shared_ptr cmd, const query::partition_range& pr, tracing::trace_state_ptr trace_state); future>> query_partition_key_range(lw_shared_ptr cmd, std::vector partition_ranges, db::consistency_level cl, tracing::trace_state_ptr trace_state); std::vector get_restricted_ranges(keyspace& ks, const schema& s, query::partition_range range); @@ -306,7 +306,7 @@ public: lw_shared_ptr cmd, std::vector&& partition_ranges, db::consistency_level cl, - tracing::trace_state_ptr trace_state = nullptr); + tracing::trace_state_ptr trace_state); future>> query_mutations_locally( schema_ptr, lw_shared_ptr cmd, const query::partition_range&, diff --git a/tests/database_test.cc b/tests/database_test.cc index 05a71f8818..bb458fe311 100644 --- a/tests/database_test.cc +++ b/tests/database_test.cc @@ -59,21 +59,21 @@ SEASTAR_TEST_CASE(test_querying_with_limits) { { auto cmd = query::read_command(s->id(), s->version(), partition_slice_builder(*s).build(), 3); - auto result = db.query(s, cmd, query::result_request::only_result, pranges).get0(); + auto result = db.query(s, cmd, query::result_request::only_result, pranges, nullptr).get0(); assert_that(query::result_set::from_raw_result(s, cmd.slice, *result)).has_size(3); } { auto cmd = query::read_command(s->id(), s->version(), partition_slice_builder(*s).build(), query::max_rows, gc_clock::now(), std::experimental::nullopt, 5); - auto result = db.query(s, cmd, query::result_request::only_result, pranges).get0(); + auto result = db.query(s, cmd, query::result_request::only_result, pranges, nullptr).get0(); assert_that(query::result_set::from_raw_result(s, cmd.slice, *result)).has_size(5); } { auto cmd = query::read_command(s->id(), s->version(), partition_slice_builder(*s).build(), query::max_rows, gc_clock::now(), std::experimental::nullopt, 3); - auto result = db.query(s, cmd, query::result_request::only_result, pranges).get0(); + auto result = db.query(s, cmd, query::result_request::only_result, pranges, nullptr).get0(); assert_that(query::result_set::from_raw_result(s, cmd.slice, *result)).has_size(3); } });