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

Method StartProducing

cpp/src/arrow/acero/map_node.cc:56–59  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

54const Ordering& MapNode::ordering() const { return inputs_[0]->ordering(); }
55
56Status MapNode::StartProducing() {
57 NoteStartProducing(ToStringExtra());
58 return Status::OK();
59}
60
61void MapNode::PauseProducing(ExecNode* output, int32_t counter) {
62 inputs_[0]->PauseProducing(this, counter);

Callers 10

TESTFunction · 0.45
ARROW_ASSIGN_OR_RAISEFunction · 0.45
CheckValidTestCasesFunction · 0.45
CheckErrorTestCasesFunction · 0.45
CheckWholeAggregateCaseFunction · 0.45
TESTFunction · 0.45
RunGroupByFunction · 0.45
TESTFunction · 0.45

Calls 1

OKFunction · 0.50

Tested by 9

TESTFunction · 0.36
ARROW_ASSIGN_OR_RAISEFunction · 0.36
CheckValidTestCasesFunction · 0.36
CheckErrorTestCasesFunction · 0.36
CheckWholeAggregateCaseFunction · 0.36
TESTFunction · 0.36
RunGroupByFunction · 0.36
TESTFunction · 0.36