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

Method OutputBatchCallback

cpp/src/arrow/acero/tpch_node.cc:3404–3406  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

3402
3403 private:
3404 Status OutputBatchCallback(ExecBatch batch) {
3405 return output_->InputReceived(this, std::move(batch));
3406 }
3407
3408 Status FinishedCallback(int64_t total_num_batches) {
3409 ARROW_RETURN_NOT_OK(

Callers 1

StartProducingMethod · 0.95

Calls 1

InputReceivedMethod · 0.45

Tested by

no test coverage detected