Class EventTimeTriggers
- java.lang.Object
-
- org.apache.flink.table.runtime.operators.window.groupwindow.triggers.EventTimeTriggers
-
public class EventTimeTriggers extends Object
ATrigger
that 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 class
EventTimeTriggers.AfterEndOfWindow<W extends Window>
ATrigger
that fires once the watermark passes the end of the window to which a pane belongs.static class
EventTimeTriggers.AfterEndOfWindowEarlyAndLate<W extends Window>
A compositeTrigger
that consist of AfterEndOfWindow and a early trigger and late trigger.static class
EventTimeTriggers.AfterEndOfWindowNoLate<W extends Window>
A compositeTrigger
that 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.
-
-