Uses of Class
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator

Packages that use WindowOperator

Package	Description
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.

Uses of WindowOperator in org.apache.flink.streaming.runtime.operators.windowing

Subclasses of WindowOperator in org.apache.flink.streaming.runtime.operators.windowing

Modifier and Type	Class and Description
class	EvictingWindowOperator<K,IN,OUT,W extends Window> A WindowOperator that also allows an Evictor to be used.

Methods in org.apache.flink.streaming.runtime.operators.windowing that return WindowOperator

Modifier and Type	Method and Description
<ACC,V,R> WindowOperator<K,T,?,R,W>	WindowOperatorBuilder.aggregate(AggregateFunction<T,ACC,V> aggregateFunction, ProcessWindowFunction<V,R,K,W> windowFunction, TypeInformation<ACC> accumulatorType)
<ACC,V,R> WindowOperator<K,T,?,R,W>	WindowOperatorBuilder.aggregate(AggregateFunction<T,ACC,V> aggregateFunction, WindowFunction<V,R,K,W> windowFunction, TypeInformation<ACC> accumulatorType)
<R> WindowOperator<K,T,?,R,W>	WindowOperatorBuilder.apply(WindowFunction<T,R,K,W> function)
<R> WindowOperator<K,T,?,R,W>	WindowOperatorBuilder.process(ProcessWindowFunction<T,R,K,W> function)
<R> WindowOperator<K,T,?,R,W>	WindowOperatorBuilder.reduce(ReduceFunction<T> reduceFunction, ProcessWindowFunction<T,R,K,W> function)
<R> WindowOperator<K,T,?,R,W>	WindowOperatorBuilder.reduce(ReduceFunction<T> reduceFunction, WindowFunction<T,R,K,W> function)