Uses of Package
org.apache.flink.streaming.api.windowing.triggers
-
Packages that use org.apache.flink.streaming.api.windowing.triggers Package Description org.apache.flink.streaming.api.datastream org.apache.flink.streaming.api.windowing.assigners org.apache.flink.streaming.api.windowing.triggers org.apache.flink.streaming.runtime.operators.windowing This package contains the operators that implement the various window operations on data streams. -
Classes in org.apache.flink.streaming.api.windowing.triggers used by org.apache.flink.streaming.api.datastream Class Description Trigger ATriggerdetermines when a pane of a window should be evaluated to emit the results for that part of the window. -
Classes in org.apache.flink.streaming.api.windowing.triggers used by org.apache.flink.streaming.api.windowing.assigners Class Description Trigger ATriggerdetermines when a pane of a window should be evaluated to emit the results for that part of the window.Trigger.OnMergeContext Extension ofTrigger.TriggerContextthat is given toTrigger.onMerge(Window, OnMergeContext).Trigger.TriggerContext A context object that is given toTriggermethods to allow them to register timer callbacks and deal with state.TriggerResult Result type for trigger methods. -
Classes in org.apache.flink.streaming.api.windowing.triggers used by org.apache.flink.streaming.api.windowing.triggers Class Description ContinuousEventTimeTrigger ATriggerthat continuously fires based on a given time interval.ContinuousProcessingTimeTrigger ATriggerthat continuously fires based on a given time interval as measured by the clock of the machine on which the job is running.CountTrigger ATriggerthat fires once the count of elements in a pane reaches the given count.DeltaTrigger ATriggerthat fires based on aDeltaFunctionand a threshold.EventTimeTrigger ATriggerthat fires once the watermark passes the end of the window to which a pane belongs.ProcessingTimeoutTrigger ProcessingTimeTrigger ATriggerthat fires once the current system time passes the end of the window to which a pane belongs.PurgingTrigger A trigger that can turn anyTriggerinto a purgingTrigger.Trigger ATriggerdetermines when a pane of a window should be evaluated to emit the results for that part of the window.Trigger.OnMergeContext Extension ofTrigger.TriggerContextthat is given toTrigger.onMerge(Window, OnMergeContext).Trigger.TriggerContext A context object that is given toTriggermethods to allow them to register timer callbacks and deal with state.TriggerResult Result type for trigger methods. -
Classes in org.apache.flink.streaming.api.windowing.triggers used by org.apache.flink.streaming.runtime.operators.windowing Class Description Trigger ATriggerdetermines when a pane of a window should be evaluated to emit the results for that part of the window.Trigger.OnMergeContext Extension ofTrigger.TriggerContextthat is given toTrigger.onMerge(Window, OnMergeContext).Trigger.TriggerContext A context object that is given toTriggermethods to allow them to register timer callbacks and deal with state.TriggerResult Result type for trigger methods.