| 175 | } |
| 176 | |
| 177 | Status StopProducingImpl() override { |
| 178 | // An AsyncGenerator must always be finished. So we go ahead and |
| 179 | // close the producer. However, for custom sink nodes, we don't want |
| 180 | // to bother ordering and sending output so we don't call Finish |
| 181 | producer_.Close(); |
| 182 | return Status::OK(); |
| 183 | } |
| 184 | |
| 185 | Status Validate() const override { |
| 186 | ARROW_RETURN_NOT_OK(ExecNode::Validate()); |