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

Method PauseProducing

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

Source from the content-addressed store, hash-verified

59}
60
61void MapNode::PauseProducing(ExecNode* output, int32_t counter) {
62 inputs_[0]->PauseProducing(this, counter);
63}
64
65void MapNode::ResumeProducing(ExecNode* output, int32_t counter) {
66 inputs_[0]->ResumeProducing(this, counter);

Callers 1

ProcessBatchMethod · 0.45

Calls

no outgoing calls

Tested by 1

ProcessBatchMethod · 0.36