org.apache.reef.vortex.common

Class AggregateFunctionRepository

java.lang.Object

org.apache.reef.vortex.common.AggregateFunctionRepository

@ThreadSafe
public final class AggregateFunctionRepository
extends Object

A repository for VortexAggregateFunction and its associated VortexFunction, used to pass functions between VortexMaster and RunningWorkers, as well as used to cache functions for VortexWorkers on AggregateRequests and AggregateExecutionRequests.

Method Summary

Methods

Modifier and Type	Method and Description
VortexAggregateFunction	getAggregateFunction(int aggregateFunctionId) Gets the VortexAggregateFunction associated with the aggregate function ID.
VortexFunction	getFunction(int aggregateFunctionId) Gets the VortexFunction associated with the aggregate function ID.
VortexAggregatePolicy	getPolicy(int aggregateFunctionId) Gets the VortexAggregatePolicy associated with the aggregate function ID.
org.apache.commons.lang3.tuple.Triple<VortexAggregateFunction,VortexFunction,VortexAggregatePolicy>	put(int aggregateFunctionId, VortexAggregateFunction aggregateFunction, VortexFunction function, VortexAggregatePolicy policy) Associates an aggregate function ID with a VortexAggregateFunction and a VortexFunction.

Methods inherited from class java.lang.Object

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

Method Detail

put

public org.apache.commons.lang3.tuple.Triple<VortexAggregateFunction,VortexFunction,VortexAggregatePolicy> put(int aggregateFunctionId,
                                                                                                      VortexAggregateFunction aggregateFunction,
                                                                                                      VortexFunction function,
                                                                                                      VortexAggregatePolicy policy)

Associates an aggregate function ID with a VortexAggregateFunction and a VortexFunction.

getAggregateFunction

public VortexAggregateFunction getAggregateFunction(int aggregateFunctionId)

Gets the VortexAggregateFunction associated with the aggregate function ID.

getFunction

public VortexFunction getFunction(int aggregateFunctionId)

Gets the VortexFunction associated with the aggregate function ID.

getPolicy

public VortexAggregatePolicy getPolicy(int aggregateFunctionId)

Gets the VortexAggregatePolicy associated with the aggregate function ID.