Function mz_compute::sink::materialized_view_v2::persist_source

source ยท 
fn persist_source<S>(
    scope: &mut S,
    sink_id: GlobalId,
    target: CollectionMetadata,
    compute_state: &ComputeState,
    start_signal: StartSignal,
) -> (OkErr<Stream<S, (Row, Timestamp, Diff)>, Stream<S, (DataflowError, Timestamp, Diff)>>, Box<dyn Any>)
where
    S: Scope<Timestamp = Timestamp>,
Expand description

Instantiate a persist source reading back the target collection.