Package | Description |
---|---|
org.apache.flink.streaming.api.scala |
Modifier and Type | Method and Description |
---|---|
AllWindowedStream<T,W> |
AllWindowedStream.allowedLateness(Time lateness)
Sets the allowed lateness to a user-specified value.
|
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,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> |
DataStream.windowAll(WindowAssigner<? super T,W> assigner)
Windows this data stream to a
AllWindowedStream , which evaluates windows
over a key grouped stream. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.