Skip to main content

Module watermark_check

risingwave_stream::executor::wrapper

Module watermark_check 

Source

Functionsยง

watermark_check
Streams wrapped by watermark_check will check that no row falls below a watermark emitted earlier on the same column. A delete of an upsert stream is not checked, as only its stream key identifies the row it deletes.