Uses of Class
org.apache.flink.streaming.api.datastream.WindowedStream

Packages that use WindowedStream

Package	Description
org.apache.flink.streaming.api.datastream

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

Methods in org.apache.flink.streaming.api.datastream that return WindowedStream

Modifier and Type	Method and Description
WindowedStream<T,K,W>	WindowedStream.allowedLateness(Time lateness) Sets the time by which elements are allowed to be late.
WindowedStream<T,KEY,GlobalWindow>	KeyedStream.countWindow(long size) Windows this KeyedStream into tumbling count windows.
WindowedStream<T,KEY,GlobalWindow>	KeyedStream.countWindow(long size, long slide) Windows this KeyedStream into sliding count windows.
WindowedStream<T,K,W>	WindowedStream.evictor(Evictor<? super T,? super W> evictor) Sets the Evictor that should be used to evict elements from a window before emission.
WindowedStream<T,K,W>	WindowedStream.sideOutputLateData(OutputTag<T> outputTag) Send late arriving data to the side output identified by the given OutputTag.
WindowedStream<T,KEY,TimeWindow>	KeyedStream.timeWindow(Time size) Deprecated. Please use KeyedStream.window(WindowAssigner) with either TumblingEventTimeWindows or TumblingProcessingTimeWindows. For more information, see the deprecation notice on TimeCharacteristic
WindowedStream<T,KEY,TimeWindow>	KeyedStream.timeWindow(Time size, Time slide) Deprecated. Please use KeyedStream.window(WindowAssigner) with either SlidingEventTimeWindows or SlidingProcessingTimeWindows. For more information, see the deprecation notice on TimeCharacteristic
WindowedStream<T,K,W>	WindowedStream.trigger(Trigger<? super T,? super W> trigger) Sets the Trigger that should be used to trigger window emission.
<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.