| 77 | }; |
| 78 | |
| 79 | Status AggregateUdfConsume(compute::KernelContext* ctx, const compute::ExecSpan& batch) { |
| 80 | return checked_cast<ScalarUdfAggregator*>(ctx->state())->Consume(ctx, batch); |
| 81 | } |
| 82 | |
| 83 | Status AggregateUdfMerge(compute::KernelContext* ctx, compute::KernelState&& src, |
| 84 | compute::KernelState* dst) { |