Function mz_compute::sink::materialized_view_v2::mint::render

source ยท
pub fn render<S>(
    name: String,
    persist_api: PersistApi,
    as_of: Antichain<Timestamp>,
    active_worker_id: usize,
    read_only_rx: Receiver<bool>,
    desired: &OkErr<Stream<S, (Row, Timestamp, Diff)>, Stream<S, (DataflowError, Timestamp, Diff)>>,
) -> (OkErr<Stream<S, (Row, Timestamp, Diff)>, Stream<S, (DataflowError, Timestamp, Diff)>>, Stream<S, BatchDescription>, Box<dyn Any>)
where S: Scope<Timestamp = Timestamp>,