ray.data.block.BlockAccessor.combine

BlockAccessor.combine(key: SortKey, aggs: Tuple[AggregateFn]) → pyarrow.Table | pandas.DataFrame

Combine rows with the same key into an accumulator.