Function mz_compute::sink::persist_sink::persist_sink

pub(crate) fn persist_sink<G>(
    sink_id: GlobalId,
    target: &CollectionMetadata,
    desired_collection: Collection<G, Result<Row, DataflowError>, Diff>,
    as_of: Antichain<Timestamp>,
    compute_state: &mut ComputeState
) -> Option<Rc<dyn Any>>where
    G: Scope<Timestamp = Timestamp>,