Package org.apache.flink.api.common.aggregators

Class AggregatorRegistry

java.lang.Object

org.apache.flink.api.common.aggregators.AggregatorRegistry

@Internal
public class AggregatorRegistry
extends Object

A registry for iteration Aggregators.

Constructor Summary

Constructors

Constructor	Description
AggregatorRegistry()

Method Summary

Modifier and Type	Method	Description
void	addAll(AggregatorRegistry registry)
Collection<AggregatorWithName<?>>	getAllRegisteredAggregators()
ConvergenceCriterion<?>	getConvergenceCriterion()
String	getConvergenceCriterionAggregatorName()
<T extends Value> void	registerAggregationConvergenceCriterion(String name, Aggregator<T> aggregator, ConvergenceCriterion<T> convergenceCheck)
void	registerAggregator(String name, Aggregator<?> aggregator)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggregatorRegistry

public AggregatorRegistry()

Method Detail

registerAggregator

public void registerAggregator(String name,
                               Aggregator<?> aggregator)

getAllRegisteredAggregators

public Collection<AggregatorWithName<?>> getAllRegisteredAggregators()

registerAggregationConvergenceCriterion

public <T extends Value> void registerAggregationConvergenceCriterion(String name,
                                                                      Aggregator<T> aggregator,
                                                                      ConvergenceCriterion<T> convergenceCheck)

getConvergenceCriterionAggregatorName

public String getConvergenceCriterionAggregatorName()

getConvergenceCriterion

public ConvergenceCriterion<?> getConvergenceCriterion()

addAll

public void addAll(AggregatorRegistry registry)