Uses of Class
org.apache.flink.streaming.api.windowing.assigners.WindowAssigner

Packages that use WindowAssigner

Package	Description
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.windowing.assigners
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.

Uses of WindowAssigner in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type WindowAssigner

Modifier and Type	Method and Description
<W extends Window> CoGroupedStreams.WithWindow<T1,T2,KEY,W>	CoGroupedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner) Specifies the window on which the co-group operation works.
<W extends Window> JoinedStreams.WithWindow<T1,T2,KEY,W>	JoinedStreams.Where.EqualTo.window(WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> assigner) Specifies the window on which the join operation works.
<W extends Window> WindowedStream<T,KEY,W>	KeyedStream.window(WindowAssigner<? super T,W> assigner) Windows this data stream to a WindowedStream, which evaluates windows over a key grouped stream.
<W extends Window> AllWindowedStream<T,W>	DataStream.windowAll(WindowAssigner<? super T,W> assigner) Windows this data stream to a KeyedTriggerWindowDataStream, which evaluates windows over a key grouped stream.

Constructors in org.apache.flink.streaming.api.datastream with parameters of type WindowAssigner

Constructor and Description
AllWindowedStream(DataStream<T> input, WindowAssigner<? super T,W> windowAssigner)
WindowedStream(KeyedStream<T,K> input, WindowAssigner<? super T,W> windowAssigner)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, KeySelector<T1,KEY> keySelector1, KeySelector<T2,KEY> keySelector2, TypeInformation<KEY> keyType, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor, Time allowedLateness)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, KeySelector<T1,KEY> keySelector1, KeySelector<T2,KEY> keySelector2, TypeInformation<KEY> keyType, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor, Time allowedLateness)

Uses of WindowAssigner in org.apache.flink.streaming.api.windowing.assigners

Subclasses of WindowAssigner in org.apache.flink.streaming.api.windowing.assigners

Modifier and Type	Class and Description
class	BaseAlignedWindowAssigner Deprecated. will be removed in a future version. please use other WindowAssigners listed under org.apache.flink.streaming.api.windowing.assigners.
class	DynamicEventTimeSessionWindows<T> A WindowAssigner that windows elements into sessions based on the timestamp of the elements.
class	DynamicProcessingTimeSessionWindows<T> A WindowAssigner that windows elements into sessions based on the current processing time.
class	EventTimeSessionWindows A WindowAssigner that windows elements into sessions based on the timestamp of the elements.
class	GlobalWindows A WindowAssigner that assigns all elements to the same GlobalWindow.
class	MergingWindowAssigner<T,W extends Window> A WindowAssigner that can merge windows.
class	ProcessingTimeSessionWindows A WindowAssigner that windows elements into sessions based on the current processing time.
class	SlidingEventTimeWindows A WindowAssigner that windows elements into sliding windows based on the timestamp of the elements.
class	SlidingProcessingTimeWindows A WindowAssigner that windows elements into sliding windows based on the current system time of the machine the operation is running on.
class	SlidingTimeWindows Deprecated. Please use SlidingEventTimeWindows.
class	TumblingEventTimeWindows A WindowAssigner that windows elements into windows based on the timestamp of the elements.
class	TumblingProcessingTimeWindows A WindowAssigner that windows elements into windows based on the current system time of the machine the operation is running on.
class	TumblingTimeWindows Deprecated. Please use TumblingEventTimeWindows.

Uses of WindowAssigner in org.apache.flink.streaming.runtime.operators.windowing

Fields in org.apache.flink.streaming.runtime.operators.windowing declared as WindowAssigner

Modifier and Type	Field and Description
protected WindowAssigner<? super IN,W>	WindowOperator.windowAssigner

Methods in org.apache.flink.streaming.runtime.operators.windowing that return WindowAssigner

Modifier and Type	Method and Description
WindowAssigner<? super IN,W>	WindowOperator.getWindowAssigner()

Constructors in org.apache.flink.streaming.runtime.operators.windowing with parameters of type WindowAssigner

Constructor and Description
EvictingWindowOperator(WindowAssigner<? super IN,W> windowAssigner, TypeSerializer<W> windowSerializer, KeySelector<IN,K> keySelector, TypeSerializer<K> keySerializer, StateDescriptor<? extends ListState<StreamRecord<IN>>,?> windowStateDescriptor, InternalWindowFunction<Iterable<IN>,OUT,K,W> windowFunction, Trigger<? super IN,? super W> trigger, Evictor<? super IN,? super W> evictor, long allowedLateness, OutputTag<IN> lateDataOutputTag)
WindowOperator(WindowAssigner<? super IN,W> windowAssigner, TypeSerializer<W> windowSerializer, KeySelector<IN,K> keySelector, TypeSerializer<K> keySerializer, StateDescriptor<? extends AppendingState<IN,ACC>,?> windowStateDescriptor, InternalWindowFunction<ACC,OUT,K,W> windowFunction, Trigger<? super IN,? super W> trigger, long allowedLateness, OutputTag<IN> lateDataOutputTag) Creates a new WindowOperator based on the given policies and user functions.