Package org.apache.flink.streaming.api.windowing.triggers

Interface Summary

Interface	Description
Trigger.OnMergeContext	Extension of Trigger.TriggerContext that is given to Trigger.onMerge(Window, OnMergeContext).
Trigger.TriggerContext	A context object that is given to Trigger methods to allow them to register timer callbacks and deal with state.

Class Summary

Class	Description
ContinuousEventTimeTrigger<W extends Window>	A Trigger that continuously fires based on a given time interval.
ContinuousProcessingTimeTrigger<W extends Window>	A Trigger that continuously fires based on a given time interval as measured by the clock of the machine on which the job is running.
CountTrigger<W extends Window>	A Trigger that fires once the count of elements in a pane reaches the given count.
DeltaTrigger<T,W extends Window>	A Trigger that fires based on a DeltaFunction and a threshold.
EventTimeTrigger	A Trigger that fires once the watermark passes the end of the window to which a pane belongs.
ProcessingTimeoutTrigger<T,W extends Window>	A Trigger that can turn any Trigger into a timeout Trigger.
ProcessingTimeTrigger	A Trigger that fires once the current system time passes the end of the window to which a pane belongs.
PurgingTrigger<T,W extends Window>	A trigger that can turn any Trigger into a purging Trigger.
Trigger<T,W extends Window>	A Trigger determines when a pane of a window should be evaluated to emit the results for that part of the window.

Enum Summary

Enum	Description
TriggerResult	Result type for trigger methods.