mz_compute::sink::correction_v2

Function consolidate

Source
fn consolidate<D: Data>(updates: &mut Vec<(D, Timestamp, Diff)>)
Expand description

Sort and consolidate the given list of updates.

This function is the same as differential_dataflow::consolidation::consolidate_updates, except that it sorts updates by (time, data) instead of (data, time).