Function mz_storage::source::source_reader_pipeline::reclock_operator

source ยท 
fn reclock_operator<G, FromTime, M>(
    scope: &G,
    config: RawSourceCreationConfig,
    timestamper: ReclockFollower<FromTime, Timestamp>,
    source_rx: InstrumentedUnboundedReceiver<Event<FromTime, StackWrapper<((usize, Result<SourceMessage, DataflowError>), FromTime, Diff)>>, M>,
    remap_trace_updates: Collection<G, FromTime, Diff>,
    source_metrics: Arc<SourceMetrics>,
) -> Vec<(Collection<G, SourceOutput<FromTime>, Diff>, Collection<G, DataflowError, Diff>, SourceExportDataConfig)>
where
    G: Scope<Timestamp = Timestamp>,
    FromTime: SourceTimestamp,
    M: InstrumentedChannelMetric + 'static,
Expand description

Receives un-timestamped batches from the source reader and updates to the remap trace on a second input. This operator takes the remap information, reclocks incoming batches and sends them forward.