mz_compute::sink::correction_v2

Function merge_chains

Source
fn merge_chains<D: Data>(
    chains: impl IntoIterator<Item = Chain<D>>,
    since: &Antichain<Timestamp>,
) -> Chain<D>
Expand description

Merge the given chains, advancing times by the given since in the process.