risingwave_stream::executor::sink

Function force_append_only

Source 
fn force_append_only(c: StreamChunk) -> StreamChunk