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