ray.data.block.BlockAccessor.aggregate_combined_blocks#

static BlockAccessor.aggregate_combined_blocks(blocks: List[Union[pyarrow.Table, pandas.DataFrame]], key: Optional[str], agg: AggregateFn) → Tuple[Union[pyarrow.Table, pandas.DataFrame], ray.data.block.BlockMetadata][source]#

Aggregate partially combined and sorted blocks.