Function mz_interchange::envelopes::combine_at_timestamp

source ยท 
pub fn combine_at_timestamp<G: Scope, Tr>(
    arranged: Arranged<G, Tr>,
) -> Collection<G, (Option<Row>, Vec<DiffPair<Row>>), Diff>
where
    G::Timestamp: Lattice + Copy,
    Tr: Clone + for<'a> TraceReader<Key<'a> = &'a Option<Row>, Val<'a> = &'a Row, Time = G::Timestamp, Diff = Diff>,
    Tr::Batch: Batch,
    for<'a> Tr::TimeGat<'a>: Ord,
Expand description

Given a stream of batches, produce a stream of groups of DiffPairs, grouped by key, at each timestamp.