| 407 | } |
| 408 | |
| 409 | arrow::Status StopProducingImpl() override { |
| 410 | #ifdef ARROW_ENABLE_THREADING |
| 411 | process_queue.Clear(); |
| 412 | #endif |
| 413 | PushTask(kPoisonPill); |
| 414 | return Status::OK(); |
| 415 | } |
| 416 | |
| 417 | // handled by the backpressure controller |
| 418 | void PauseProducing(arrow::acero::ExecNode* output, int32_t counter) override {} |