mz_storage::source::source_reader_pipeline

Function demux_source_exports

Source
fn demux_source_exports<G, FromTime>(
    config: RawSourceCreationConfig,
    input: Collection<G, (usize, Result<SourceOutput<FromTime>, DataflowError>), Diff>,
) -> Vec<(GlobalId, Collection<G, SourceOutput<FromTime>, Diff>, Collection<G, DataflowError, Diff>, SourceExportDataConfig)>
where G: Scope<Timestamp = Timestamp>, FromTime: SourceTimestamp,
Expand description

Demultiplexes a combined stream of all source exports into individual collections per source export