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

Packages that use WindowedStream

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

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

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

Modifier and Type	Method and Description
WindowedStream<T,K,GlobalWindow>	KeyedStream.countWindow(long size) Windows this KeyedStream into tumbling count windows.
WindowedStream<T,K,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,TimeWindow>	KeyedStream.timeWindow(Time size) Windows this KeyedStream into tumbling time windows.
WindowedStream<T,K,TimeWindow>	KeyedStream.timeWindow(Time size, Time slide) Windows this KeyedStream into sliding time windows.
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,K,W>	KeyedStream.window(WindowAssigner<? super T,W> assigner) Windows this data stream to a WindowedStream, which evaluates windows over a key grouped stream.