ray.data.aggregate.AggregateFnV2.aggregate_block#

abstract AggregateFnV2.aggregate_block(block: pyarrow.Table | pandas.DataFrame) AggType[source]#

Applies aggregations to individual block (producing partial aggregation results)