mz_storage::render::sinks

Function zip_into_diff_pairs

Source 
fn zip_into_diff_pairs<G>(
    sink_id: GlobalId,
    sink: &StorageSinkDesc<CollectionMetadata, Timestamp>,
    sink_render: &dyn SinkRender<G>,
    collection: Collection<G, Row, Diff>,
) -> Collection<G, (Option<Row>, DiffPair<Row>), Diff>
where
    G: Scope<Timestamp = Timestamp>,
Expand description

Zip the input to a sink so that updates to the same key appear as DiffPairs.