| 65 | owned_thread_pool_(std::move(owned_thread_pool)) {} |
| 66 | |
| 67 | ~ExecPlanImpl() override { |
| 68 | if (started_ && !finished_.is_finished()) { |
| 69 | ARROW_LOG(WARNING) << "Plan was destroyed before finishing"; |
| 70 | StopProducing(); |
| 71 | finished().Wait(); |
| 72 | } |
| 73 | } |
| 74 | |
| 75 | const NodeVector& nodes() const { return node_ptrs_; } |
| 76 |
nothing calls this directly
no test coverage detected