mz_storage::source::source_reader_pipeline

Function reclock_committed_upper

Source 
fn reclock_committed_upper<G, FromTime>(
    bindings: &Collection<G, FromTime, Diff>,
    as_of: Antichain<G::Timestamp>,
    committed_upper: &Stream<G, ()>,
    id: GlobalId,
    metrics: Arc<SourceMetrics>,
) -> impl Stream<Item = Antichain<FromTime>> + 'static
where
    G: Scope,
    G::Timestamp: Lattice + TotalOrder,
    FromTime: SourceTimestamp,
Expand description

Reclocks an IntoTime frontier stream into a FromTime frontier stream. This is used for the virtual (through persist) feedback edge so that we convert the IntoTime resumption frontier into the FromTime frontier that is used with the source’s OffsetCommiter.