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