Uses of Class
org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction

Packages that use ProcessAllWindowFunction

Package	Description
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.runtime.operators.windowing.functions

Uses of ProcessAllWindowFunction in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type ProcessAllWindowFunction

Modifier and Type	Method and Description
<ACC,V,R> SingleOutputStreamOperator<R>	AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggFunction, ProcessAllWindowFunction<V,R,W> windowFunction) Applies the given window function to each window.
<ACC,V,R> SingleOutputStreamOperator<R>	AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction, ProcessAllWindowFunction<V,R,W> windowFunction, TypeInformation<ACC> accumulatorType, TypeInformation<V> aggregateResultType, TypeInformation<R> resultType) Applies the given window function to each window.
<ACC,R> SingleOutputStreamOperator<R>	AllWindowedStream.fold(ACC initialValue, FoldFunction<T,ACC> foldFunction, ProcessAllWindowFunction<ACC,R,W> function) Deprecated. use AllWindowedStream.aggregate(AggregateFunction, ProcessAllWindowFunction) instead
<ACC,R> SingleOutputStreamOperator<R>	AllWindowedStream.fold(ACC initialValue, FoldFunction<T,ACC> foldFunction, ProcessAllWindowFunction<ACC,R,W> function, TypeInformation<ACC> foldAccumulatorType, TypeInformation<R> resultType) Deprecated. use AllWindowedStream.aggregate(AggregateFunction, ProcessAllWindowFunction, TypeInformation, TypeInformation, TypeInformation) instead
<R> SingleOutputStreamOperator<R>	AllWindowedStream.process(ProcessAllWindowFunction<T,R,W> function) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	AllWindowedStream.process(ProcessAllWindowFunction<T,R,W> function, TypeInformation<R> resultType) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	AllWindowedStream.reduce(ReduceFunction<T> reduceFunction, ProcessAllWindowFunction<T,R,W> function) Applies the given window function to each window.
<R> SingleOutputStreamOperator<R>	AllWindowedStream.reduce(ReduceFunction<T> reduceFunction, ProcessAllWindowFunction<T,R,W> function, TypeInformation<R> resultType) Applies the given window function to each window.

Uses of ProcessAllWindowFunction in org.apache.flink.streaming.api.functions.windowing

Subclasses of ProcessAllWindowFunction in org.apache.flink.streaming.api.functions.windowing

Modifier and Type	Class and Description
class	FoldApplyProcessAllWindowFunction<W extends Window,T,ACC,R> Deprecated. will be removed in a future version
class	ReduceApplyProcessAllWindowFunction<W extends Window,T,R> Internal ProcessAllWindowFunction that is used for implementing a fold on a window configuration that only allows AllWindowFunction and cannot directly execute a ReduceFunction.
class	RichProcessAllWindowFunction<IN,OUT,W extends Window> Deprecated. use ProcessAllWindowFunction instead

Constructors in org.apache.flink.streaming.api.functions.windowing with parameters of type ProcessAllWindowFunction

Constructor and Description
FoldApplyProcessAllWindowFunction(ACC initialValue, FoldFunction<T,ACC> foldFunction, ProcessAllWindowFunction<ACC,R,W> windowFunction, TypeInformation<ACC> accTypeInformation) Deprecated.
ReduceApplyProcessAllWindowFunction(ReduceFunction<T> reduceFunction, ProcessAllWindowFunction<T,R,W> windowFunction)

Uses of ProcessAllWindowFunction in org.apache.flink.streaming.runtime.operators.windowing.functions

Constructors in org.apache.flink.streaming.runtime.operators.windowing.functions with parameters of type ProcessAllWindowFunction

Constructor and Description
InternalAggregateProcessAllWindowFunction(AggregateFunction<T,ACC,V> aggFunction, ProcessAllWindowFunction<V,R,W> windowFunction)
InternalIterableProcessAllWindowFunction(ProcessAllWindowFunction<IN,OUT,W> wrappedFunction)
InternalSingleValueProcessAllWindowFunction(ProcessAllWindowFunction<IN,OUT,W> wrappedFunction)