Package | Description |
---|---|
org.apache.flink.streaming.api.scala | |
org.apache.flink.streaming.api.scala.function | |
org.apache.flink.streaming.api.scala.function.util |
Modifier and Type | Method and Description |
---|---|
<ACC,V,R> DataStream<R> |
WindowedStream.aggregate(AggregateFunction<T,ACC,V> preAggregator,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> evidence$13,
TypeInformation<V> evidence$14,
TypeInformation<R> evidence$15)
Applies the given window function to each window.
|
<R,ACC> DataStream<R> |
WindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
ProcessWindowFunction<ACC,R,K,W> function,
TypeInformation<R> evidence$24,
TypeInformation<ACC> evidence$25)
Deprecated.
use [[aggregate()]] instead. Since .
|
<R,ACC> DataStream<R> |
WindowedStream.fold(ACC initialValue,
scala.Function2<ACC,T,ACC> foldFunction,
ProcessWindowFunction<ACC,R,K,W> function,
TypeInformation<R> evidence$22,
TypeInformation<ACC> evidence$23)
Deprecated.
use [[aggregate()]] instead. Since .
|
<R> DataStream<R> |
WindowedStream.process(ProcessWindowFunction<T,R,K,W> function,
TypeInformation<R> evidence$26)
Applies the given window function to each window.
|
<R> DataStream<R> |
WindowedStream.reduce(scala.Function2<T,T,T> preAggregator,
ProcessWindowFunction<T,R,K,W> function,
TypeInformation<R> evidence$3)
Applies the given reduce function to each window.
|
<R> DataStream<R> |
WindowedStream.reduce(ReduceFunction<T> preAggregator,
ProcessWindowFunction<T,R,K,W> function,
TypeInformation<R> evidence$4)
Applies the given reduce function to each window.
|
Modifier and Type | Class and Description |
---|---|
class |
RichProcessWindowFunction<IN,OUT,KEY,W extends Window>
Deprecated.
use [[ProcessWindowFunction]] instead. Since .
|
Constructor and Description |
---|
ScalaProcessWindowFunctionWrapper(ProcessWindowFunction<IN,OUT,KEY,W> func) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.