Function mz_compute::render::reduce::render_reduce_plan
source · 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.