| 504 | } |
| 505 | |
| 506 | Status InputReceived(ExecNode* input, ExecBatch batch) override { |
| 507 | auto scope = TraceInputReceived(batch); |
| 508 | |
| 509 | DCHECK_EQ(input, inputs_[0]); |
| 510 | |
| 511 | ARROW_ASSIGN_OR_RAISE(auto record_batch, |
| 512 | batch.ToRecordBatch(inputs_[0]->output_schema(), |
| 513 | plan()->query_context()->memory_pool())); |
| 514 | |
| 515 | impl_->InputReceived(std::move(record_batch)); |
| 516 | if (input_counter_.Increment()) { |
| 517 | return Finish(); |
| 518 | } |
| 519 | return Status::OK(); |
| 520 | } |
| 521 | |
| 522 | protected: |
| 523 | Status DoFinish() { |
nothing calls this directly
no test coverage detected