fn render_reduce_plan<G, T>(
    debug_name: &str,
    plan: ReducePlan,
    collection: Collection<G, (Row, Row), Diff>,
    err_input: Collection<G, DataflowError, Diff>,
    key_arity: usize
) -> CollectionBundle<G, Row, T>where
    G: Scope,
    G::Timestamp: Lattice + Refines<T>,
    T: Timestamp + Lattice,
Expand description

Render a dataflow based on the provided plan.

The output will be an arrangements that looks the same as if we just had a single reduce operator computing everything together, and this arrangement can also be re-used.