Uses of Interface
org.apache.flink.api.common.functions.AggregateFunction

Packages that use AggregateFunction

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.state
org.apache.flink.api.java.typeutils
org.apache.flink.contrib.streaming.state
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.runtime.operators.windowing.functions

Uses of AggregateFunction in org.apache.flink.api.common.functions

Classes in org.apache.flink.api.common.functions that implement AggregateFunction

Modifier and Type	Class and Description
class	RichAggregateFunction<IN,ACC,OUT> Rich variant of the AggregateFunction.

Uses of AggregateFunction in org.apache.flink.api.common.state

Methods in org.apache.flink.api.common.state that return AggregateFunction

Modifier and Type	Method and Description
AggregateFunction<IN,ACC,OUT>	AggregatingStateDescriptor.getAggregateFunction() Returns the aggregate function to be used for the state.

Constructors in org.apache.flink.api.common.state with parameters of type AggregateFunction

Constructor and Description
AggregatingStateDescriptor(String name, AggregateFunction<IN,ACC,OUT> aggFunction, Class<ACC> stateType) Creates a new state descriptor with the given name, function, and type.
AggregatingStateDescriptor(String name, AggregateFunction<IN,ACC,OUT> aggFunction, TypeInformation<ACC> stateType) Creates a new ReducingStateDescriptor with the given name and default value.
AggregatingStateDescriptor(String name, AggregateFunction<IN,ACC,OUT> aggFunction, TypeSerializer<ACC> typeSerializer) Creates a new ValueStateDescriptor with the given name and default value.

Uses of AggregateFunction in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils with parameters of type AggregateFunction

Modifier and Type	Method and Description
static <IN,ACC> TypeInformation<ACC>	TypeExtractor.getAggregateFunctionAccumulatorType(AggregateFunction<IN,ACC,?> function, TypeInformation<IN> inType, String functionName, boolean allowMissing)
static <IN,OUT> TypeInformation<OUT>	TypeExtractor.getAggregateFunctionReturnType(AggregateFunction<IN,?,OUT> function, TypeInformation<IN> inType, String functionName, boolean allowMissing)

Uses of AggregateFunction in org.apache.flink.contrib.streaming.state

Constructors in org.apache.flink.contrib.streaming.state with parameters of type AggregateFunction

Constructor and Description
RocksDBAggregatingState(org.rocksdb.ColumnFamilyHandle columnFamily, TypeSerializer<N> namespaceSerializer, TypeSerializer<ACC> valueSerializer, ACC defaultValue, AggregateFunction<T,ACC,R> aggFunction, RocksDBKeyedStateBackend<K> backend) Creates a new RocksDBAggregatingState.

Uses of AggregateFunction in org.apache.flink.runtime.state.heap

Constructors in org.apache.flink.runtime.state.heap with parameters of type AggregateFunction

Constructor and Description
HeapAggregatingState(StateTable<K,N,ACC> stateTable, TypeSerializer<K> keySerializer, TypeSerializer<ACC> valueSerializer, TypeSerializer<N> namespaceSerializer, ACC defaultValue, AggregateFunction<IN,ACC,OUT> aggregateFunction) Creates a new key/value state for the given hash map of key/value pairs.

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

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

Modifier and Type	Method and Description
<ACC,R> SingleOutputStreamOperator<R>	AllWindowedStream.aggregate(AggregateFunction<T,ACC,R> function) Applies the given AggregateFunction to each window.
<ACC,R> SingleOutputStreamOperator<R>	WindowedStream.aggregate(AggregateFunction<T,ACC,R> function) Applies the given aggregation function to each window.
<ACC,R> SingleOutputStreamOperator<R>	AllWindowedStream.aggregate(AggregateFunction<T,ACC,R> function, TypeInformation<ACC> accumulatorType, TypeInformation<R> resultType) Applies the given AggregateFunction to each window.
<ACC,R> SingleOutputStreamOperator<R>	WindowedStream.aggregate(AggregateFunction<T,ACC,R> function, TypeInformation<ACC> accumulatorType, TypeInformation<R> resultType) Applies the given aggregation function to each window.
<ACC,V,R> SingleOutputStreamOperator<R>	AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggFunction, AllWindowFunction<V,R,W> windowFunction) Applies the given window function to each window.
<ACC,V,R> SingleOutputStreamOperator<R>	AllWindowedStream.aggregate(AggregateFunction<T,ACC,V> aggregateFunction, AllWindowFunction<V,R,W> windowFunction, TypeInformation<ACC> accumulatorType, TypeInformation<V> aggregateResultType, TypeInformation<R> resultType) Applies the given window function to each window.
<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,V,R> SingleOutputStreamOperator<R>	WindowedStream.aggregate(AggregateFunction<T,ACC,V> aggFunction, ProcessWindowFunction<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, ProcessWindowFunction<V,R,K,W> windowFunction, TypeInformation<ACC> accumulatorType, TypeInformation<V> aggregateResultType, TypeInformation<R> resultType) Applies the given window function to each window.
<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.

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

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

Constructor and Description
AggregateApplyAllWindowFunction(AggregateFunction<T,ACC,V> aggFunction, AllWindowFunction<V,R,W> windowFunction)
AggregateApplyWindowFunction(AggregateFunction<T,ACC,V> aggFunction, WindowFunction<V,R,K,W> windowFunction)

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

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

Constructor and Description
InternalAggregateProcessAllWindowFunction(AggregateFunction<T,ACC,V> aggFunction, ProcessAllWindowFunction<V,R,W> windowFunction)
InternalAggregateProcessWindowFunction(AggregateFunction<T,ACC,V> aggFunction, ProcessWindowFunction<V,R,K,W> windowFunction)