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

Function HashAggregateUdfMerge

python/pyarrow/src/arrow/python/udf.cc:100–104  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

98}
99
100Status HashAggregateUdfMerge(KernelContext* ctx, KernelState&& src,
101 const ArrayData& group_id_mapping) {
102 return checked_cast<HashUdfAggregator*>(ctx->state())
103 ->Merge(ctx, std::move(src), group_id_mapping);
104}
105
106Status HashAggregateUdfFinalize(KernelContext* ctx, Datum* out) {
107 return checked_cast<HashUdfAggregator*>(ctx->state())->Finalize(ctx, out);

Callers

nothing calls this directly

Calls 2

MergeMethod · 0.45
stateMethod · 0.45

Tested by

no test coverage detected