MCPcopy Create free account
hub / github.com/apache/arrow / ~ExecPlanImpl

Method ~ExecPlanImpl

cpp/src/arrow/acero/exec_plan.cc:67–73  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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

Callers

nothing calls this directly

Calls 2

is_finishedMethod · 0.45
WaitMethod · 0.45

Tested by

no test coverage detected