Function mz_compute::sink::materialized_view_v2::write::render

source ยท
pub fn render<S>(
    name: String,
    persist_api: PersistApi,
    desired: &OkErr<Stream<S, (Row, Timestamp, Diff)>, Stream<S, (DataflowError, Timestamp, Diff)>>,
    persist: &OkErr<Stream<S, (Row, Timestamp, Diff)>, Stream<S, (DataflowError, Timestamp, Diff)>>,
    descs: &Stream<S, BatchDescription>,
) -> (Stream<S, ProtoBatch>, Box<dyn Any>)
where S: Scope<Timestamp = Timestamp>,