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

Method InputFinished

cpp/src/arrow/acero/source_node.cc:120–120  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

118 }
119 [[noreturn]] Status InputReceived(ExecNode*, ExecBatch) override { NoInputs(); }
120 [[noreturn]] Status InputFinished(ExecNode*, int) override { NoInputs(); }
121
122 void SliceAndDeliverMorsel(const ExecBatch& morsel) {
123 bool use_legacy_batching = plan_->query_context()->options().use_legacy_batching;

Callers 1

ARROW_ASSIGN_OR_RAISEMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected