mz_storage::source::source_reader_pipeline

Function remap_operator

Source 
fn remap_operator<G, FromTime>(
    scope: &G,
    config: RawSourceCreationConfig,
    probed_upper: Receiver<Option<Probe<FromTime>>>,
    ingested_upper: Receiver<MutableAntichain<FromTime>>,
    remap_relation_desc: RelationDesc,
) -> (Collection<G, FromTime, Diff>, PressOnDropButton)
where
    G: Scope<Timestamp = Timestamp>,
    FromTime: SourceTimestamp,
Expand description

Mints new contents for the remap shard based on summaries about the source upper it receives from the raw reader operators.

Only one worker will be active and write to the remap shard. All source upper summaries will be exchanged to it.