Package org.apache.reef.vortex.api

Vortex user api for running jobs on Vortex.

See: Description

Interface Summary

Interface	Description
FutureCallback<V>	A callback for accepting the results of a VortexFuture computation asynchronously.
VortexAggregateFunction<TOutput>	Typed user function for Local Aggregation.
VortexFunction<TInput,TOutput>	Typed user function.
VortexStart	The starting point of Vortex user thread.

Class Summary

Class	Description
AggregateResult<TInput,TOutput>	The result of an aggregate.
AggregateResultSynchronous<TInput,TOutput>	The synchronous result of an aggregate, returned by VortexAggregateFuture.get().
VortexAggregateFuture<TInput,TOutput>	The interface between user code and aggregation Tasklets.
VortexAggregatePolicy	The policy for local aggregation on the VortexWorkers.
VortexAggregatePolicy.AggregatePolicyBuilder	A Builder class for VortexAggregatePolicy.
VortexFuture<TOutput>	The interface between user code and submitted task.
VortexThreadPool	Distributed thread pool.

Exception Summary

Exception	Description
VortexAggregateException	Exception thrown when an aggregate function fails.

Package org.apache.reef.vortex.api Description

Vortex user api for running jobs on Vortex.