| 85 | } |
| 86 | |
| 87 | std::shared_ptr<ReadStorageRowCountStep> |
| 88 | ReadStorageRowCountStep::fromProto(const Protos::ReadStorageRowCountStep & proto, ContextPtr) |
| 89 | { |
| 90 | auto base_output_header = ISourceStep::deserializeFromProtoBase(proto.query_plan_base()); |
| 91 | auto query = deserializeASTFromProto(proto.query()); |
| 92 | AggregateDescription agg_desc; |
| 93 | agg_desc.fillFromProto(proto.agg_desc()); |
| 94 | auto num_rows = proto.num_rows(); |
| 95 | bool is_final = proto.is_final_agg(); |
| 96 | auto step = std::make_shared<ReadStorageRowCountStep>(base_output_header, query, agg_desc, num_rows, is_final); |
| 97 | |
| 98 | return step; |
| 99 | } |
| 100 | } |
nothing calls this directly
no test coverage detected