Class EventTimeTriggers
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.window.triggers.EventTimeTriggers
-
public class EventTimeTriggers extends Object
ATriggerthat reacts to event-time timers. The behavior can be one of the following:-
fire when the watermark passes the end of the window (
afterEndOfWindow()),In the first case, the trigger can also specify an early and a late trigger. The early trigger will be responsible for specifying when the trigger should fire in the period between the beginning of the window and the time when the watermark passes the end of the window. The late trigger takes over after the watermark passes the end of the window, and specifies when the trigger should fire in the period between the endOfWindow and endOfWindow + allowedLateness.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classEventTimeTriggers.AfterEndOfWindow<W extends Window>ATriggerthat fires once the watermark passes the end of the window to which a pane belongs.static classEventTimeTriggers.AfterEndOfWindowEarlyAndLate<W extends Window>A compositeTriggerthat consist of AfterEndOfWindow and a early trigger and late trigger.static classEventTimeTriggers.AfterEndOfWindowNoLate<W extends Window>A compositeTriggerthat consist of AfterEndOfWindow and a late trigger.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <W extends Window>
EventTimeTriggers.AfterEndOfWindow<W>afterEndOfWindow()Creates a trigger that fires when the watermark passes the end of the window.
-
-
-
Method Detail
-
afterEndOfWindow
public static <W extends Window> EventTimeTriggers.AfterEndOfWindow<W> afterEndOfWindow()
Creates a trigger that fires when the watermark passes the end of the window.
-
-