Uses of Interface
org.apache.flink.api.common.aggregators.Aggregator

Packages that use Aggregator

Package	Description
org.apache.flink.api.common.aggregators
org.apache.flink.api.common.functions
org.apache.flink.api.common.operators.base

Uses of Aggregator in org.apache.flink.api.common.aggregators

Classes in org.apache.flink.api.common.aggregators that implement Aggregator

Modifier and Type	Class	Description
class	DoubleSumAggregator	An Aggregator that sums up DoubleValue values.
class	LongSumAggregator	An Aggregator that sums up long values.

Methods in org.apache.flink.api.common.aggregators that return Aggregator

Modifier and Type	Method	Description
Aggregator<T>	AggregatorWithName.getAggregator()	Gets the aggregator.

Methods in org.apache.flink.api.common.aggregators with parameters of type Aggregator

Modifier and Type	Method	Description
<T extends Value> void	AggregatorRegistry.registerAggregationConvergenceCriterion(String name, Aggregator<T> aggregator, ConvergenceCriterion<T> convergenceCheck)
void	AggregatorRegistry.registerAggregator(String name, Aggregator<?> aggregator)

Constructors in org.apache.flink.api.common.aggregators with parameters of type Aggregator

Constructor	Description
AggregatorWithName(String name, Aggregator<T> aggregator)	Creates a new instance for the given aggregator and name.

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

Methods in org.apache.flink.api.common.functions with type parameters of type Aggregator

Modifier and Type	Method	Description
<T extends Aggregator<?>> T	IterationRuntimeContext.getIterationAggregator(String name)

Uses of Aggregator in org.apache.flink.api.common.operators.base

Classes in org.apache.flink.api.common.operators.base that implement Aggregator

Modifier and Type	Class	Description
static class	BulkIterationBase.TerminationCriterionAggregator	Aggregator that basically only adds 1 for every output tuple of the termination criterion branch