Skip to main content

execute_map_reduce_distributed

Function execute_map_reduce_distributed 

Source
pub async fn execute_map_reduce_distributed(
    config: &MapReduceConfig,
    router: &MessageRouter,
    coordinator: FighterId,
) -> PunchResult<MapReduceResult>
Expand description

Execute a MapReduce operation by actually distributing work via the message router. Splits the input, sends chunks to workers, and merges results.