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

Method ExecChunked

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

Source from the content-addressed store, hash-verified

1111 }
1112
1113 Status ExecChunked(const ExecBatch& batch, ExecListener* listener) {
1114 RETURN_NOT_OK(CheckCanExecuteChunked(kernel_));
1115 Datum out;
1116 ARROW_ASSIGN_OR_RAISE(out.value, PrepareOutput(batch.length));
1117 RETURN_NOT_OK(kernel_->exec_chunked(kernel_ctx_, batch, &out));
1118 if (out.is_array()) {
1119 return EmitResult(out.array(), listener);
1120 } else {
1121 DCHECK(out.is_chunked_array());
1122 return EmitResult(out.chunked_array(), listener);
1123 }
1124 }
1125
1126 ExecSpanIterator span_iterator_;
1127 std::vector<Datum> results_;

Callers

nothing calls this directly

Calls 6

CheckCanExecuteChunkedFunction · 0.85
PrepareOutputFunction · 0.85
is_arrayMethod · 0.80
chunked_arrayMethod · 0.80
ARROW_ASSIGN_OR_RAISEFunction · 0.50
arrayMethod · 0.45

Tested by

no test coverage detected