Skip to main content

watermark_check

risingwave_stream::executor::wrapper::watermark_check

Function watermark_check 

Source 
pub fn watermark_check(
    info: Arc<ExecutorInfo>,
    input: impl MessageStream,
) -> impl MessageStream
Expand description

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.

It is a combinator rather than a generator, which would deepen the stack of every executor in debug builds.