| 3378 | [[noreturn]] Status InputFinished(ExecNode*, int) override { NoInputs(); } |
| 3379 | |
| 3380 | Status StartProducing() override { |
| 3381 | RETURN_NOT_OK(generator_->StartProducing( |
| 3382 | plan_->query_context()->max_concurrency(), |
| 3383 | [this](ExecBatch batch) { return this->OutputBatchCallback(std::move(batch)); }, |
| 3384 | [this](int64_t num_batches) { return this->FinishedCallback(num_batches); }, |
| 3385 | [this](std::function<Status(size_t)> func) -> Status { |
| 3386 | return this->ScheduleTaskCallback(std::move(func)); |
| 3387 | })); |
| 3388 | return Status::OK(); |
| 3389 | } |
| 3390 | |
| 3391 | void PauseProducing(ExecNode* output, int32_t counter) override { |
| 3392 | // TODO(ARROW-16087) |
nothing calls this directly
no test coverage detected