Function dataflow::render::reduce::render_reduce_plan[][src]

fn render_reduce_plan<G, T>(
    plan: ReducePlan,
    collection: Collection<G, (Row, Row)>,
    err_input: Collection<G, DataflowError>,
    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.