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