<ACC,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(org.apache.flink.api.common.functions.AggregateFunction<T,ACC,R> function) |
Applies the given aggregation function to each window.
|
<ACC,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(org.apache.flink.api.common.functions.AggregateFunction<T,ACC,R> function,
org.apache.flink.api.common.typeinfo.TypeInformation<ACC> accumulatorType) |
Applies the given aggregation function to each window.
|
<ACC,V,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(org.apache.flink.api.common.functions.AggregateFunction<T,ACC,V> aggFunction,
org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction<V,R,K,W> windowFunction) |
Applies the given window function to each window.
|
<ACC,V,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(org.apache.flink.api.common.functions.AggregateFunction<T,ACC,V> aggregateFunction,
org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction<V,R,K,W> windowFunction,
org.apache.flink.api.common.typeinfo.TypeInformation<ACC> accumulatorType) |
Applies the given window function to each window.
|
<ACC,V,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(org.apache.flink.api.common.functions.AggregateFunction<T,ACC,V> aggFunction,
org.apache.flink.streaming.api.functions.windowing.WindowFunction<V,R,K,W> windowFunction) |
Applies the given window function to each window.
|
<ACC,V,R> BootstrapTransformation<T> |
WindowedOperatorTransformation.aggregate(org.apache.flink.api.common.functions.AggregateFunction<T,ACC,V> aggregateFunction,
org.apache.flink.streaming.api.functions.windowing.WindowFunction<V,R,K,W> windowFunction,
org.apache.flink.api.common.typeinfo.TypeInformation<ACC> accumulatorType) |
Applies the given window function to each window.
|
<R> BootstrapTransformation<T> |
WindowedOperatorTransformation.apply(org.apache.flink.streaming.api.functions.windowing.WindowFunction<T,R,K,W> function) |
Applies the given window function to each window.
|
<R> BootstrapTransformation<T> |
WindowedOperatorTransformation.apply(org.apache.flink.streaming.api.functions.windowing.WindowFunction<T,R,K,W> function,
org.apache.flink.api.common.typeinfo.TypeInformation<R> resultType) |
Applies the given window function to each window.
|
<R> BootstrapTransformation<T> |
WindowedOperatorTransformation.process(org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction<T,R,K,W> function) |
Applies the given window function to each window.
|
BootstrapTransformation<T> |
WindowedOperatorTransformation.reduce(org.apache.flink.api.common.functions.ReduceFunction<T> function) |
Applies a reduce function to the window.
|
<R> BootstrapTransformation<T> |
WindowedOperatorTransformation.reduce(org.apache.flink.api.common.functions.ReduceFunction<T> reduceFunction,
org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction<T,R,K,W> function) |
Applies the given window function to each window.
|
<R> BootstrapTransformation<T> |
WindowedOperatorTransformation.reduce(org.apache.flink.api.common.functions.ReduceFunction<T> reduceFunction,
org.apache.flink.streaming.api.functions.windowing.WindowFunction<T,R,K,W> function) |
Applies the given window function to each window.
|
BootstrapTransformation<T> |
KeyedOperatorTransformation.transform(KeyedStateBootstrapFunction<K,T> processFunction) |
Deprecated.
|
BootstrapTransformation<T> |
KeyedOperatorTransformation.transform(SavepointWriterOperatorFactory factory) |
Deprecated.
Method for passing user defined operators along with the type information that will transform
the OperatorTransformation.
|
BootstrapTransformation<T> |
OneInputOperatorTransformation.transform(BroadcastStateBootstrapFunction<T> processFunction) |
Deprecated.
|
BootstrapTransformation<T> |
OneInputOperatorTransformation.transform(StateBootstrapFunction<T> processFunction) |
Deprecated.
|
BootstrapTransformation<T> |
OneInputOperatorTransformation.transform(SavepointWriterOperatorFactory factory) |
Deprecated.
Method for passing user defined operators along with the type information that will transform
the OperatorTransformation.
|