@ThreadSafe public final class AggregateFunctionRepository extends Object
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.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 . |
public org.apache.commons.lang3.tuple.Triple<VortexAggregateFunction,VortexFunction,VortexAggregatePolicy> put(int aggregateFunctionId, VortexAggregateFunction aggregateFunction, VortexFunction function, VortexAggregatePolicy policy)
VortexAggregateFunction
and a VortexFunction
.public VortexAggregateFunction getAggregateFunction(int aggregateFunctionId)
VortexAggregateFunction
associated with the aggregate function ID.public VortexFunction getFunction(int aggregateFunctionId)
VortexFunction
associated with the aggregate function ID.public VortexAggregatePolicy getPolicy(int aggregateFunctionId)
VortexAggregatePolicy
associated with the aggregate function ID.Copyright © 2016 The Apache Software Foundation. All rights reserved.