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

fn build_distinct_retractions<G, T>(
    collection: Collection<G, (Row, Row)>
) -> Collection<G, Row> where
    G: Scope,
    G::Timestamp: Lattice + Refines<T>,
    T: Timestamp + Lattice
Expand description

Build the dataflow to compute the set of distinct keys.

This implementation maintains the rows that don’t appear in the output.