| 404 | } |
| 405 | |
| 406 | std::string GroupByNode::ToStringExtra(int indent) const { |
| 407 | std::stringstream ss; |
| 408 | const auto input_schema = inputs_[0]->output_schema(); |
| 409 | ss << "keys=["; |
| 410 | for (size_t i = 0; i < key_field_ids_.size(); i++) { |
| 411 | if (i > 0) ss << ", "; |
| 412 | ss << '"' << input_schema->field(key_field_ids_[i])->name() << '"'; |
| 413 | } |
| 414 | ss << "], "; |
| 415 | AggregatesToString(&ss, *input_schema, aggs_, agg_src_fieldsets_, indent); |
| 416 | return ss.str(); |
| 417 | } |
| 418 | |
| 419 | Status GroupByNode::InitLocalStateIfNeeded(ThreadLocalState* state) { |
| 420 | // Get input schema |
nothing calls this directly
no test coverage detected