ray.data.block.BlockAccessor.combine#

BlockAccessor.combine(key: Optional[str], agg: AggregateFn) → Union[pyarrow.Table, pandas.DataFrame][source]#

Combine rows with the same key into an accumulator.