ray.data.aggregate.AggregateFnV2.combine

abstract AggregateFnV2.combine(current_accumulator: AggType, new: AggType) → AggType

Combines new partially aggregated value (previously returned from aggregate_block partial aggregations into a singular partial aggregation) with the previously stored accumulator