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> |
AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> preAggregator,
ProcessAllWindowFunction<V,R,W> windowFunction,
TypeInformation<ACC> evidence$10,
TypeInformation<V> evidence$11,
TypeInformation<R> evidence$12)
Applies the given window function to each window.
|
<ACC,R> DataStream<R> |
AllWindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> preAggregator,
ProcessAllWindowFunction<ACC,R,W> windowFunction,
TypeInformation<ACC> evidence$20,
TypeInformation<R> evidence$21)
Deprecated.
use [[aggregate()]] instead. Since .
|
<ACC,R> DataStream<R> |
AllWindowedStream.fold(ACC initialValue,
scala.Function2<ACC,T,ACC> preAggregator,
ProcessAllWindowFunction<ACC,R,W> windowFunction,
TypeInformation<ACC> evidence$24,
TypeInformation<R> evidence$25)
Deprecated.
use [[aggregate()]] instead. Since .
|
<R> DataStream<R> |
AllWindowedStream.process(ProcessAllWindowFunction<T,R,W> function,
TypeInformation<R> evidence$26)
Applies the given window function to each window.
|
<R> DataStream<R> |
AllWindowedStream.reduce(scala.Function2<T,T,T> preAggregator,
ProcessAllWindowFunction<T,R,W> windowFunction,
TypeInformation<R> evidence$4)
Applies the given window function to each window.
|
<R> DataStream<R> |
AllWindowedStream.reduce(ReduceFunction<T> preAggregator,
ProcessAllWindowFunction<T,R,W> windowFunction,
TypeInformation<R> evidence$3)
Applies the given window function to each window.
|
Modifier and Type | Class and Description |
---|---|
class |
RichProcessAllWindowFunction<IN,OUT,W extends Window>
Deprecated.
use [[ProcessAllWindowFunction]] instead. Since .
|
Constructor and Description |
---|
ScalaProcessAllWindowFunctionWrapper(ProcessAllWindowFunction<IN,OUT,W> func) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.