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

Method OutputBatchCallback

cpp/src/arrow/acero/hash_join_node.cc:1025–1027  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1023
1024 private:
1025 Status OutputBatchCallback(ExecBatch batch) {
1026 return output_->InputReceived(this, std::move(batch));
1027 }
1028
1029 Status FinishedCallback(int64_t total_num_batches) {
1030 bool expected = false;

Callers 1

InitMethod · 0.95

Calls 1

InputReceivedMethod · 0.45

Tested by

no test coverage detected