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

Interface Summary

Interface	Description
MergingWindowAssigner.MergeCallback<W>	Callback to be used in MergingWindowAssigner.mergeWindows(Collection, MergeCallback) for specifying which windows should be merged.

Class Summary

Class	Description
BaseAlignedWindowAssigner	A base WindowAssigner used to instantiate one of the deprecated AccumulatingProcessingTimeWindowOperator and AggregatingProcessingTimeWindowOperator.
EventTimeSessionWindows	A WindowAssigner that windows elements into sessions based on the timestamp of the elements.
GlobalWindows	A WindowAssigner that assigns all elements to the same GlobalWindow.
GlobalWindows.NeverTrigger	A trigger that never fires, as default Trigger for GlobalWindows.
MergingWindowAssigner<T,W extends Window>	A WindowAssigner that can merge windows.
ProcessingTimeSessionWindows	A WindowAssigner that windows elements into sessions based on the current processing time.
SlidingAlignedProcessingTimeWindows	This is a special window assigner used to tell the system to use the "Fast Aligned Processing Time Window Operator" for windowing.
SlidingEventTimeWindows	A WindowAssigner that windows elements into sliding windows based on the timestamp of the elements.
SlidingProcessingTimeWindows	A WindowAssigner that windows elements into sliding windows based on the current system time of the machine the operation is running on.
SlidingTimeWindows	Deprecated Please use SlidingEventTimeWindows.
TumblingEventTimeWindows	A WindowAssigner that windows elements into windows based on the timestamp of the elements.
TumblingProcessingTimeWindows	A WindowAssigner that windows elements into windows based on the current system time of the machine the operation is running on.
TumblingTimeWindows	Deprecated Please use TumblingEventTimeWindows.
WindowAssigner<T,W extends Window>	A WindowAssigner assigns zero or more Windows to an element.
WindowAssigner.WindowAssignerContext	A context provided to the WindowAssigner that allows it to query the current processing time.