Function mz_storage::source::source_reader_pipeline::remap_operator

source ยท 
fn remap_operator<G, FromTime>(
    scope: &G,
    storage_state: &StorageState,
    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.