| 1528 | void ResumeProducing(ExecNode* output, int32_t counter) override {} |
| 1529 | |
| 1530 | Status StopProducingImpl() override { |
| 1531 | #ifdef ARROW_ENABLE_THREADING |
| 1532 | process_.Clear(); |
| 1533 | #endif |
| 1534 | PushProcess(false); |
| 1535 | return Status::OK(); |
| 1536 | } |
| 1537 | |
| 1538 | #ifndef NDEBUG |
| 1539 | std::ostream* GetDebugStream() { return debug_os_; } |