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

Packages that use AllWindowedStream

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

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

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

Modifier and Type	Method and Description
AllWindowedStream<T,W>	AllWindowedStream.allowedLateness(Time lateness) Sets the time by which elements are allowed to be late.
AllWindowedStream<T,GlobalWindow>	DataStream.countWindowAll(long size) Windows this DataStream into tumbling count windows.
AllWindowedStream<T,GlobalWindow>	DataStream.countWindowAll(long size, long slide) Windows this DataStream into sliding count windows.
AllWindowedStream<T,W>	AllWindowedStream.evictor(Evictor<? super T,? super W> evictor) Sets the Evictor that should be used to evict elements from a window before emission.
AllWindowedStream<T,W>	AllWindowedStream.sideOutputLateData(OutputTag<T> outputTag) Send late arriving data to the side output identified by the given OutputTag.
AllWindowedStream<T,TimeWindow>	DataStream.timeWindowAll(Time size) Windows this DataStream into tumbling time windows.
AllWindowedStream<T,TimeWindow>	DataStream.timeWindowAll(Time size, Time slide) Windows this DataStream into sliding time windows.
AllWindowedStream<T,W>	AllWindowedStream.trigger(Trigger<? super T,? super W> trigger) Sets the Trigger that should be used to trigger window emission.
<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.