| 94 | } |
| 95 | |
| 96 | Status HashAggregateUdfConsume(KernelContext* ctx, const ExecSpan& batch) { |
| 97 | return checked_cast<HashUdfAggregator*>(ctx->state())->Consume(ctx, batch); |
| 98 | } |
| 99 | |
| 100 | Status HashAggregateUdfMerge(KernelContext* ctx, KernelState&& src, |
| 101 | const ArrayData& group_id_mapping) { |