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>