| 258 | } |
| 259 | |
| 260 | Status ScalarAggregateNode::InputFinished(ExecNode* input, int total_batches) { |
| 261 | auto scope = TraceFinish(); |
| 262 | EVENT_ON_CURRENT_SPAN("InputFinished", {{"batches.length", total_batches}}); |
| 263 | DCHECK_EQ(input, inputs_[0]); |
| 264 | if (input_counter_.SetTotal(total_batches)) { |
| 265 | RETURN_NOT_OK(OutputResult(/*is_last=*/true)); |
| 266 | } |
| 267 | return Status::OK(); |
| 268 | } |
| 269 | |
| 270 | std::string ScalarAggregateNode::ToStringExtra(int indent) const { |
| 271 | std::stringstream ss; |