Skip to main content

zip_into_diff_pairs

Function zip_into_diff_pairs 

Source
fn zip_into_diff_pairs<'scope>(
    sink_id: GlobalId,
    sink: &StorageSinkDesc<CollectionMetadata, Timestamp>,
    sink_render: &dyn SinkRender<'scope>,
    collection: VecCollection<'scope, Timestamp, Row, Diff>,
) -> VecCollection<'scope, Timestamp, (Option<Row>, DiffPair<Row>), Diff>
Expand description

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