Skip to main content

Module watermark_trigger

risingwave_stream::executor::over_window

Module watermark_trigger 

Source

Structs§

TriggerEntry 🔒
A partition to check once the watermark of the order key satisfies the bound.
TriggersPostCommit 🔒
WatermarkTriggers 🔒
The triggers of the partitions whose next rows to output may be closed by watermark, indexed by bound, so that a watermark only visits the partitions whose triggers it satisfies.

Functions§

cache_key 🔒