Uses of Interface
org.apache.reef.vortex.api.VortexAggregateFunction

Packages that use VortexAggregateFunction

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.
org.apache.reef.vortex.examples.sumones	A Simple Vortex addition and aggregation example.

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

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

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 VortexAggregateFunction in org.apache.reef.vortex.common

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

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

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

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 VortexAggregateFunction

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 VortexAggregateFunction

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

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

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

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.

Uses of VortexAggregateFunction in org.apache.reef.vortex.examples.sumones

Classes in org.apache.reef.vortex.examples.sumones that implement VortexAggregateFunction

Modifier and Type	Class and Description
class	AdditionAggregateFunction Aggregates and sums the outputs.