python/ray/data/grouped_dataset.py
def reduce(
        key: KeyFn, aggs: Tuple[AggregateFn], *mapper_outputs: List[Block]
    ) -> (Block, BlockMetadata):
        """Aggregate sorted and partially combined blocks."""
        return BlockAccessor.for_block(mapper_outputs[0]).aggregate_combined_blocks(
            list(mapper_outputs), key, aggs
        )
Aggregate sorted and partially combined blocks.
Aggregate sorted and partially combined blocks.
Aggregate sorted and partially combined blocks .
def reduce(
        key: KeyFn, aggs: Tuple[AggregateFn], *mapper_outputs: List[Block]
    ) -> (Block, BlockMetadata):
        return BlockAccessor.for_block(mapper_outputs[0]).aggregate_combined_blocks(
            list(mapper_outputs), key, aggs
        )
def reduce ( key : KeyFn , aggs : Tuple [ AggregateFn ] , * mapper_outputs : List [ Block ] ) -> ( Block , BlockMetadata ) : return BlockAccessor . for_block ( mapper_outputs [ 0 ] ) . aggregate_combined_blocks ( list ( mapper_outputs ) , key , aggs )
Aggregate sorted and partially combined blocks.
Aggregate sorted and partially combined blocks .
"""Aggregate sorted and partially combined blocks."""
key
KeyFn
aggs
Tuple[AggregateFn]
mapper_outputs
List[Block]