Package | Description |
---|---|
org.apache.flink.streaming.api.scala | |
org.apache.flink.streaming.api.scala.function.util |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
WindowedStream.apply(ReduceFunction<T> preAggregator,
WindowFunction<T,R,K,W> function,
TypeInformation<R> evidence$11)
Deprecated.
Use
reduce(ReduceFunction, WindowFunction) instead. |
<R> DataStream<R> |
WindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
WindowFunction<R,R,K,W> function,
TypeInformation<R> evidence$13)
Deprecated.
Use
fold(R, FoldFunction, WindowFunction) instead. |
<R> DataStream<R> |
WindowedStream.apply(WindowFunction<T,R,K,W> function,
TypeInformation<R> evidence$9)
Applies the given window function to each window.
|
<ACC,R> DataStream<R> |
WindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
WindowFunction<ACC,R,K,W> function,
TypeInformation<ACC> evidence$5,
TypeInformation<R> evidence$6)
Applies the given window function to each window.
|
<R> DataStream<R> |
WindowedStream.reduce(ReduceFunction<T> preAggregator,
WindowFunction<T,R,K,W> function,
TypeInformation<R> evidence$1)
Applies the given window function to each window.
|
Constructor and Description |
---|
ScalaWindowFunctionWrapper(WindowFunction<IN,OUT,KEY,W> func) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.