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

Method StartProducing

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

Source from the content-addressed store, hash-verified

994 }
995
996 Status StartProducing() override {
997 NoteStartProducing(ToStringExtra());
998 RETURN_NOT_OK(
999 pushdown_context_.StartProducing(plan_->query_context()->GetThreadIndex()));
1000 return Status::OK();
1001 }
1002
1003 void PauseProducing(ExecNode* output, int32_t counter) override {
1004 // TODO(ARROW-16246)

Callers

nothing calls this directly

Calls 4

GetThreadIndexMethod · 0.80
query_contextMethod · 0.80
OKFunction · 0.50
StartProducingMethod · 0.45

Tested by

no test coverage detected