org.apache.flink.runtime.iterative.task

Class RuntimeAggregatorRegistry

java.lang.Object

org.apache.flink.runtime.iterative.task.RuntimeAggregatorRegistry

public class RuntimeAggregatorRegistry
extends Object

Constructor Summary

Constructors

Constructor and Description
RuntimeAggregatorRegistry(Collection<AggregatorWithName<?>> aggs)

Method Summary

Modifier and Type	Method and Description
<T extends Aggregator<?>> T	getAggregator(String name)
Map<String,Aggregator<?>>	getAllAggregators()
Value	getPreviousGlobalAggregate(String name)
void	updateGlobalAggregatesAndReset(String[] names, Value[] aggregates)

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeAggregatorRegistry

public RuntimeAggregatorRegistry(Collection<AggregatorWithName<?>> aggs)

Method Detail

getPreviousGlobalAggregate

public Value getPreviousGlobalAggregate(String name)

getAggregator

public <T extends Aggregator<?>> T getAggregator(String name)

getAllAggregators

public Map<String,Aggregator<?>> getAllAggregators()

updateGlobalAggregatesAndReset

public void updateGlobalAggregatesAndReset(String[] names,
                                           Value[] aggregates)