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>)