Function hydro_test::cluster::map_reduce::map_reduce

source ยท 
pub fn map_reduce<'a>(
    flow: &FlowBuilder<'a>,
) -> (Process<'a, Leader>, Cluster<'a, Worker>)