| 994 | } |
| 995 | |
| 996 | Status StartProducing() override { |
| 997 | NoteStartProducing(ToStringExtra()); |
| 998 | RETURN_NOT_OK( |
| 999 | pushdown_context_.StartProducing(plan_->query_context()->GetThreadIndex())); |
| 1000 | return Status::OK(); |
| 1001 | } |
| 1002 | |
| 1003 | void PauseProducing(ExecNode* output, int32_t counter) override { |
| 1004 | // TODO(ARROW-16246) |
nothing calls this directly
no test coverage detected