map_reduce

Function map_reduce 

Source
pub fn map_reduce(
    mapper: AgentBuilder,
    reducer: AgentBuilder,
    list_key: impl Into<String>,
) -> Composable
Expand description

Map-reduce: map mapper over the list at list_key, then run reducer over the collected results (state["_results"]). A pipeline of a map_over node and the reducer.