Uses of Interface
org.apache.flink.streaming.api.functions.windowing.WindowFunction

Packages that use WindowFunction

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

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

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

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

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

Classes in org.apache.flink.streaming.api.functions.windowing that implement WindowFunction

Modifier and Type	Class and Description
class	AggregateApplyWindowFunction<K,W extends Window,T,ACC,V,R> A WindowFunction that composes an AggregateFunction and WindowFunction.
class	FoldApplyWindowFunction<K,W extends Window,T,ACC,R> Deprecated. will be removed in a future version
class	PassThroughWindowFunction<K,W extends Window,T> A WindowFunction that just emits each input element.
class	ReduceApplyWindowFunction<K,W extends Window,T,R> Internal WindowFunction that is used for implementing a fold on a window configuration that only allows WindowFunction and cannot directly execute a ReduceFunction.
class	RichWindowFunction<IN,OUT,KEY,W extends Window> Rich variant of the WindowFunction.

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

Constructor and Description
AggregateApplyWindowFunction(AggregateFunction<T,ACC,V> aggFunction, WindowFunction<V,R,K,W> windowFunction)
FoldApplyWindowFunction(ACC initialValue, FoldFunction<T,ACC> foldFunction, WindowFunction<ACC,R,K,W> windowFunction, TypeInformation<ACC> accTypeInformation) Deprecated.
ReduceApplyWindowFunction(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> windowFunction)

Uses of WindowFunction in org.apache.flink.streaming.python.api.datastream

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

Modifier and Type	Method and Description
PythonSingleOutputStreamOperator	PythonWindowedStream.apply(WindowFunction<org.python.core.PyObject,Object,Object,W> fun) A thin wrapper layer over WindowedStream.apply(WindowFunction).

Uses of WindowFunction in org.apache.flink.streaming.python.api.functions

Classes in org.apache.flink.streaming.python.api.functions that implement WindowFunction

Modifier and Type	Class and Description
class	PythonApplyFunction<W extends Window> The PythonApplyFunction is a thin wrapper layer over a Python UDF WindowFunction.

Constructors in org.apache.flink.streaming.python.api.functions with parameters of type WindowFunction

Constructor and Description
PythonApplyFunction(WindowFunction<org.python.core.PyObject,Object,Object,W> fun)

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

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

Constructor and Description
InternalIterableWindowFunction(WindowFunction<IN,OUT,KEY,W> wrappedFunction)
InternalSingleValueWindowFunction(WindowFunction<IN,OUT,KEY,W> wrappedFunction)