public class ProcessingTimeTriggers extends Object
Trigger
that reacts to processing-time timers.
The behavior can be one of the following:
afterEndOfWindow()
),
every(Duration)
).
Modifier and Type | Class and Description |
---|---|
static class |
ProcessingTimeTriggers.AfterEndOfWindow<W extends Window>
A
Trigger that fires once the current system time passes the end of the window
to which a pane belongs. |
static class |
ProcessingTimeTriggers.AfterEndOfWindowNoLate<W extends Window>
A composite
Trigger that consist of AfterEndOfWindow and a early trigger. |
static class |
ProcessingTimeTriggers.AfterFirstElementPeriodic<W extends Window>
Trigger every a given interval, the first trigger time is interval
after the first element in the pane.
|
Modifier and Type | Method and Description |
---|---|
static <W extends Window> |
afterEndOfWindow()
Creates a trigger that fires when the processing time passes the end of the window.
|
static <W extends Window> |
every(java.time.Duration time)
Creates a trigger that fires by a certain interval after reception of the first element.
|
public static <W extends Window> ProcessingTimeTriggers.AfterEndOfWindow<W> afterEndOfWindow()
public static <W extends Window> ProcessingTimeTriggers.AfterFirstElementPeriodic<W> every(java.time.Duration time)
time
- the certain intervalCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.