Skip to main content

render_source_stream

Function render_source_stream 

Source
fn render_source_stream<'scope, FromTime>(
    scope: Scope<'scope, Timestamp>,
    dataflow_debug_name: &String,
    export_id: GlobalId,
    ok_source: VecCollection<'scope, Timestamp, SourceOutput<FromTime>, Diff>,
    data_config: SourceExportDataConfig,
    description: &IngestionDescription<CollectionMetadata>,
    error_collections: &mut Vec<VecCollection<'scope, Timestamp, DataflowError, Diff>>,
    storage_state: &StorageState,
    base_source_config: &RawSourceCreationConfig,
    rehydrated_token: impl Any + 'static,
) -> (VecCollection<'scope, Timestamp, Row, Diff>, Vec<PressOnDropButton>, Vec<StreamVec<'scope, Timestamp, HealthStatusMessage>>)
where FromTime: Timestamp + Sync,
Expand description

Completes the rendering of a particular source stream by applying decoding and envelope processing as necessary