flow::compute::render::reduce

Function reduce_subgraph

Source 
fn reduce_subgraph(
    _: &ReduceArrange,
    data: impl IntoIterator<Item = (Row, i64, i64)>,
    key_val_plan: &KeyValPlan,
    reduce_plan: &ReducePlan,
    _: SubgraphArg<'_>,
)
Expand description

reduce subgraph, reduce the input data into a single row output is concat from key and val