Package | Description |
---|---|
org.apache.flink.streaming.api.scala | |
org.apache.flink.streaming.api.scala.function.util |
Modifier and Type | Method and Description |
---|---|
<ACC,V,R> DataStream<R> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> preAggregator,
AllWindowFunction<V,R,W> windowFunction,
TypeInformation<ACC> evidence$7,
TypeInformation<V> evidence$8,
TypeInformation<R> evidence$9)
Applies the given window function to each window.
|
<R> DataStream<R> |
AllWindowedStream.apply(AllWindowFunction<T,R,W> function,
TypeInformation<R> evidence$27)
Applies the given window function to each window.
|
<R> DataStream<R> |
AllWindowedStream.apply(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> windowFunction,
TypeInformation<R> evidence$29)
Deprecated.
Use
reduce(ReduceFunction, AllWindowFunction) instead. |
<R> DataStream<R> |
AllWindowedStream.apply(R initialValue,
FoldFunction<T,R> preAggregator,
AllWindowFunction<R,R,W> windowFunction,
TypeInformation<R> evidence$31)
Deprecated.
Use
fold(R, FoldFunction, AllWindowFunction) instead. |
<ACC,R> DataStream<R> |
AllWindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> preAggregator,
AllWindowFunction<ACC,R,W> windowFunction,
TypeInformation<ACC> evidence$18,
TypeInformation<R> evidence$19)
Deprecated.
use [[aggregate()]] instead. Since .
|
<R> DataStream<R> |
AllWindowedStream.reduce(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> windowFunction,
TypeInformation<R> evidence$1)
Applies the given window function to each window.
|
Constructor and Description |
---|
ScalaAllWindowFunctionWrapper(AllWindowFunction<IN,OUT,W> func) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.