| 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_; |
nothing calls this directly
no test coverage detected