Skip to main content

drop_deletes_of_reinserted_keys

risingwave_stream::executor::sink

Function drop_deletes_of_reinserted_keys 

Source 
fn drop_deletes_of_reinserted_keys(
    delete_chunks: Vec<StreamChunk>,
    insert_chunks: &[StreamChunk],
    downstream_pk: &[usize],
) -> Vec<StreamChunk>