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

query-request: Add reversed function to reverse read_command

Browse Source 
The read_command is reversed by reversing the schema version it
holds and transforming a slice from the legacy reversed format to
the native reversed format.

Use for trasition between format and to support mixed-nodes clusters
This commit is contained in:
Łukasz Paszkowski
2024-06-10 12:51:55 +02:00
parent 9690785112
commit b91edbacf1
2 changed files with 25 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
query-request.hh
View File

@@ -475,6 +475,12 @@ public:
friend std::ostream& operator<<(std::ostream& out, const read_command& r);
};
// Reverse read_command by reversing the schema version and transforming the slice from
// the legacy reversed format to native reversed format. Shall be called with reversed
// queries only.
lw_shared_ptr<query::read_command> reversed(lw_shared_ptr<query::read_command>&& cmd);
query::read_command reversed(query::read_command&& cmd);
struct mapreduce_request {
enum class reduction_type {
count,
@@ -484,7 +490,7 @@ struct mapreduce_request {
db::functions::function_name name;
std::vector<sstring> column_names;
};
struct reductions_info {
struct reductions_info {
// Used by selector_factries to prepare reductions information
std::vector<reduction_type> types;
std::vector<aggregation_info> infos;

18
query.cc
View File

@@ -61,6 +61,24 @@ std::ostream& operator<<(std::ostream& out, const read_command& r) {
return out;
}
lw_shared_ptr<query::read_command> reversed(lw_shared_ptr<query::read_command>&& cmd)
{
auto schema = local_schema_registry().get(cmd->schema_version)->get_reversed();
cmd->schema_version = schema->version();
cmd->slice = query::legacy_reverse_slice_to_native_reverse_slice(*schema, cmd->slice);
return std::move(cmd);
}
query::read_command reversed(query::read_command&& cmd)
{
auto schema = local_schema_registry().get(cmd.schema_version)->get_reversed();
cmd.schema_version = schema->version();
cmd.slice = query::legacy_reverse_slice_to_native_reverse_slice(*schema, cmd.slice);
return std::move(cmd);
}
std::ostream& operator<<(std::ostream& out, const mapreduce_request::reduction_type& r) {
out << "reduction_type{";
switch (r) {