Package org.openspaces.core.executor.support

Interface Summary

DelegatingTask<T extends Serializable>	A delegating task is a task that holds another task that will be executed.
ProcessObjectsProvider	An interface used with Task allowing to return additional objects to be processed on the node the task is executed.

Class Summary

AbstractDelegatingDistributedTask<T extends Serializable,R>	A base class for delegating tasks that are also distributed tasks
AsyncResultFuture<T>	A wrapper that implemetns Future that wras an already arrived AsyncResult.
AvgReducer<T extends Number,R extends Number>	A default implementation of a reducer that averages all types T into a result R.
AvgTask<T extends Number,R extends Number>	A sum distrubted task that accepts a Task to delegate the actual execution to and implements the AvgTask.reduce(java.util.List) operation.
MaxReducer<T extends Number>	A default implementation of a reducer that returnt the maximum of T.
MaxTask<T extends Number>	A max distrubted task that accepts a Task to delegate the actual execution to and implements the MaxTask.reduce(java.util.List) operation.
MinReducer<T extends Number>	A default implementation of a reducer that returnt the minimum of T.
MinTask<T extends Number>	A min distrubted task that accepts a Task to delegate the actual execution to and implements the MinTask.reduce(java.util.List) operation.
PrivilegedDistributedTask<T extends Serializable,R>	A delegating distrubuted task (with an optional filter) that runs under established access control settings.
PrivilegedTask<T extends Serializable>	A delegating task that runs under established access control settings.
SimpleDelegatingDistributedTask<T extends Serializable,R>	A simple impelemntation of delegating distributed task that accepts the task to delegate to.
SimpleDelegatingTask<T extends Serializable>	A simple impelemntation of delegating task that accepts the task to delegate to.
SumReducer<T extends Number,R extends Number>	A default implementation of a reducer that sums all types T into a result R.
SumTask<T extends Number,R extends Number>	A sum distrubted task that accepts a Task to delegate the actual execution to and implements the SumTask.reduce(java.util.List) operation.
WaitForAllListener<T>	A listener that can be used to set on several execution and then wait for all the results (using WaitForAllListener.waitForResult().
WaitForAnyListener<T>	A listener that can be used to set on several execution and then wait for any of the results (using WaitForAnyListener.waitForResult().

Exception Summary

NoResultsException

An exception indicating there are no results to reduce.