MCPcopy Create free account
hub / github.com/apache/arrow / StopProducingImpl

Method StopProducingImpl

cpp/src/arrow/acero/sink_node.cc:177–183  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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());

Callers

nothing calls this directly

Calls 2

OKFunction · 0.50
CloseMethod · 0.45

Tested by

no test coverage detected