public class EventTimeTriggers extends Object
Trigger
that reacts to event-time timers. The behavior can be one of the following:
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.
Modifier and Type | Class and Description |
---|---|
static class |
EventTimeTriggers.AfterEndOfWindow<W extends Window>
A
Trigger that fires once the watermark passes the end of the window to which a pane
belongs. |
static class |
EventTimeTriggers.AfterEndOfWindowEarlyAndLate<W extends Window>
A composite
Trigger that consist of AfterEndOfWindow and a early trigger and late
trigger. |
static class |
EventTimeTriggers.AfterEndOfWindowNoLate<W extends Window>
A composite
Trigger that consist of AfterEndOfWindow and a late trigger. |
Modifier and Type | Method and Description |
---|---|
static <W extends Window> |
afterEndOfWindow()
Creates a trigger that fires when the watermark passes the end of the window.
|
public static <W extends Window> EventTimeTriggers.AfterEndOfWindow<W> afterEndOfWindow()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.