flow::compute::render::reduce

Function reduce_batch_subgraph

Source 
fn reduce_batch_subgraph(
    arrange: &ArrangeHandler,
    src_data: impl IntoIterator<Item = Batch>,
    key_val_plan: &KeyValPlan,
    accum_plan: &AccumulablePlan,
    output_type: &RelationType,
    _: SubgraphArg<'_, TeeingHandoff<Batch>>,
)