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

Method EmitResult

cpp/src/arrow/compute/exec.cc:1092–1101  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1090
1091 protected:
1092 Status EmitResult(Datum result, ExecListener* listener) {
1093 if (!kernel_->finalize) {
1094 // If there is no result finalizer (e.g. for hash-based functions, we can
1095 // emit the processed batch right away rather than waiting
1096 RETURN_NOT_OK(listener->OnResult(std::move(result)));
1097 } else {
1098 results_.emplace_back(std::move(result));
1099 }
1100 return Status::OK();
1101 }
1102
1103 Status Exec(const ExecSpan& span, ExecListener* listener) {
1104 ExecResult out;

Callers

nothing calls this directly

Calls 3

OnResultMethod · 0.80
emplace_backMethod · 0.80
OKFunction · 0.50

Tested by

no test coverage detected