Uses of Class
org.apache.reef.vortex.api.VortexAggregatePolicy

Packages that use VortexAggregatePolicy

Package	Description
org.apache.reef.vortex.api	Vortex user api for running jobs on Vortex.
org.apache.reef.vortex.common	Vortex Code used both in Vortex Driver and Vortex Evaluator.
org.apache.reef.vortex.driver	Vortex Code that runs as part of REEF Driver.

Uses of VortexAggregatePolicy in org.apache.reef.vortex.api

Methods in org.apache.reef.vortex.api that return VortexAggregatePolicy

Modifier and Type	Method and Description
VortexAggregatePolicy	VortexAggregatePolicy.AggregatePolicyBuilder.build() Builds and returns a new VortexAggregatePolicy based on user's specification.

Methods in org.apache.reef.vortex.api with parameters of type VortexAggregatePolicy

Modifier and Type	Method and Description
<TInput,TOutput> VortexAggregateFuture<TInput,TOutput>	VortexThreadPool.submit(VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy, List<TInput> inputs)
<TInput,TOutput> VortexAggregateFuture<TInput,TOutput>	VortexThreadPool.submit(VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy, List<TInput> inputs, FutureCallback<AggregateResult<TInput,TOutput>> callback)

Uses of VortexAggregatePolicy in org.apache.reef.vortex.common

Methods in org.apache.reef.vortex.common that return VortexAggregatePolicy

Modifier and Type	Method and Description
VortexAggregatePolicy	TaskletAggregationRequest.getPolicy()
VortexAggregatePolicy	AggregateFunctionRepository.getPolicy(int aggregateFunctionId) Gets the VortexAggregatePolicy associated with the aggregate function ID.

Methods in org.apache.reef.vortex.common that return types with arguments of type VortexAggregatePolicy

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

Methods in org.apache.reef.vortex.common with parameters of type VortexAggregatePolicy

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

Constructors in org.apache.reef.vortex.common with parameters of type VortexAggregatePolicy

Constructor and Description
TaskletAggregationRequest(int aggregateFunctionId, VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> function, VortexAggregatePolicy policy)

Uses of VortexAggregatePolicy in org.apache.reef.vortex.driver

Methods in org.apache.reef.vortex.driver with parameters of type VortexAggregatePolicy

Modifier and Type	Method and Description
<TInput,TOutput> VortexAggregateFuture<TInput,TOutput>	VortexMaster.enqueueTasklets(VortexAggregateFunction<TOutput> aggregateFunction, VortexFunction<TInput,TOutput> vortexFunction, VortexAggregatePolicy policy, List<TInput> inputs, Optional<FutureCallback<AggregateResult<TInput,TOutput>>> callback) Submits aggregate-able Tasklets to be run sometime in the future, with an optional callback function on the aggregation progress.