Package org.apache.flink.runtime.iterative.concurrent

Class IterationAggregatorBroker

java.lang.Object

org.apache.flink.runtime.iterative.concurrent.Broker<RuntimeAggregatorRegistry>

org.apache.flink.runtime.iterative.concurrent.IterationAggregatorBroker

public class IterationAggregatorBroker
extends Broker<RuntimeAggregatorRegistry>

Broker for RuntimeAggregatorRegistry.

Constructor Summary

Constructors

Constructor	Description
IterationAggregatorBroker()

Method Summary

Modifier and Type	Method	Description
static IterationAggregatorBroker	instance()	Retrieve singleton instance.

Methods inherited from class org.apache.flink.runtime.iterative.concurrent.Broker

get, getAndRemove, handIn, remove

Methods inherited from class java.lang.Object

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

Constructor Detail

IterationAggregatorBroker

public IterationAggregatorBroker()

Method Detail

instance

public static IterationAggregatorBroker instance()

Retrieve singleton instance.