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:
- AsyncResultFilter<T>, 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
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,
AsyncResultFilter<T> filter)
reduce
public R reduce(List<AsyncResult<T>> asyncResults)
throws Exception
- Throws:
Exception
Copyright © GigaSpaces.