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<(GlobalId, 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.