Function mz_storage::render::sinks::apply_sink_envelope

source · 
fn apply_sink_envelope<G>(
    sink_id: GlobalId,
    sink: &StorageSinkDesc<MetadataFilled, Timestamp>,
    sink_render: &Box<dyn SinkRender<G>>,
    collection: Collection<G, Row, Diff>,
) -> Collection<G, (Option<Row>, Option<Row>), Diff>
where
    G: Scope<Timestamp = Timestamp>,