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.