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

Method StopProducingImpl

cpp/src/arrow/acero/hash_join_node.cc:1011–1017  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1009 }
1010
1011 Status StopProducingImpl() override {
1012 bool expected = false;
1013 if (complete_.compare_exchange_strong(expected, true)) {
1014 impl_->Abort([]() {});
1015 }
1016 return Status::OK();
1017 }
1018
1019 protected:
1020 std::string ToStringExtra(int indent = 0) const override {

Callers

nothing calls this directly

Calls 2

OKFunction · 0.50
AbortMethod · 0.45

Tested by

no test coverage detected