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

Method StartPoller

cpp/src/arrow/acero/sorted_merge_node.cc:602–602  ·  view source on GitHub ↗

The entry point for processThread

Source from the content-addressed store, hash-verified

600
601 /// The entry point for processThread
602 static void StartPoller(SortedMergeNode* node) { node->EmitBatches(); }
603#endif
604
605 arrow::Ordering ordering_;

Callers

nothing calls this directly

Calls 1

EmitBatchesMethod · 0.80

Tested by

no test coverage detected