fn build_distinct_retractions<G, T>(
    debug_name: &str,
    collection: Collection<G, (Row, Row), Diff>
) -> (Collection<G, Row, Diff>, Collection<G, DataflowError, Diff>)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.