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

Packages that use AggregateResult

Package	Description
org.apache.reef.vortex.api	Vortex user api for running jobs on Vortex.
org.apache.reef.vortex.driver	Vortex Code that runs as part of REEF Driver.

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

Method parameters in org.apache.reef.vortex.api with type arguments of type AggregateResult

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, FutureCallback<AggregateResult<TInput,TOutput>> callback)

Constructor parameters in org.apache.reef.vortex.api with type arguments of type AggregateResult

Constructor and Description
VortexAggregateFuture(Executor executor, Map<Integer,TInput> taskletIdInputMap, Codec<TOutput> aggOutputCodec, FutureCallback<AggregateResult<TInput,TOutput>> callbackHandler)

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

Method parameters in org.apache.reef.vortex.driver with type arguments of type AggregateResult

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.