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

Method Finish

cpp/examples/arrow/engine_substrait_consumption.cc:48–56  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

46 }
47
48 arrow::Future<> Finish() override {
49 // Signal to the consumer that the last batch has been delivered
50 // (we don't do any real work in this consumer so mark it finished immediately)
51 //
52 // The returned future should only finish when all outstanding tasks have completed
53 // (after this method is called Consume is guaranteed not to be called again)
54 std::cout << "-" << tag_ << " finished" << std::endl;
55 return arrow::Future<>::MakeFinished();
56 }
57
58 private:
59 // A unique label for instances to help distinguish logging output if a plan has

Callers 15

CreateTableFunction · 0.45
ARROW_ASSIGN_OR_RAISEFunction · 0.45
GetScannerFromDatasetFunction · 0.45
GetTableFunction · 0.45
RunComputeRegisterFunction · 0.45
RunMainFunction · 0.45
GetArrayDataSampleFunction · 0.45
ExampleFunction · 0.45
VectorToColumnarTableFunction · 0.45
VisitMethod · 0.45
RunMainFunction · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected