force_delete_only

risingwave_stream::executor::sink

Function force_delete_only 

Source 
fn force_delete_only(c: StreamChunk) -> StreamChunk