org.openspaces.core.executor.support
Class SimpleDelegatingDistributedTask<T extends Serializable,R>
java.lang.Object
org.openspaces.core.executor.support.SimpleDelegatingTask<T>
org.openspaces.core.executor.support.AbstractDelegatingDistributedTask<T,R>
org.openspaces.core.executor.support.SimpleDelegatingDistributedTask<T,R>
- All Implemented Interfaces:
- com.gigaspaces.async.AsyncResultFilter<T>, com.gigaspaces.async.AsyncResultsReducer<T,R>, Serializable, DistributedTask<T,R>, DelegatingTask<T>, Task<T>, TaskRoutingProvider
public class SimpleDelegatingDistributedTask<T extends Serializable,R>
- extends AbstractDelegatingDistributedTask<T,R>
A simple impelemntation of delegating distributed task that accepts the task to delegate to.
- Author:
- kimchy
- See Also:
- Serialized Form
Nested classes/interfaces inherited from interface com.gigaspaces.async.AsyncResultFilter |
com.gigaspaces.async.AsyncResultFilter.Decision |
Method Summary |
R |
reduce(List<com.gigaspaces.async.AsyncResult<T>> asyncResults)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.openspaces.core.executor.Task |
execute |
SimpleDelegatingDistributedTask
protected SimpleDelegatingDistributedTask()
SimpleDelegatingDistributedTask
public SimpleDelegatingDistributedTask(DistributedTask<T,R> task)
SimpleDelegatingDistributedTask
public SimpleDelegatingDistributedTask(DistributedTask<T,R> task,
com.gigaspaces.async.AsyncResultFilter<T> filter)
reduce
public R reduce(List<com.gigaspaces.async.AsyncResult<T>> asyncResults)
throws Exception
- Throws:
Exception
Copyright © GigaSpaces.