GigaSpaces XAP 7.0 API

org.openspaces.core.executor.support
Class SimpleDelegatingDistributedTask<T extends Serializable,R>

java.lang.Object
  extended by org.openspaces.core.executor.support.SimpleDelegatingTask<T>
      extended by org.openspaces.core.executor.support.AbstractDelegatingDistributedTask<T,R>
          extended by 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

Nested Class Summary
 
Nested classes/interfaces inherited from interface com.gigaspaces.async.AsyncResultFilter
AsyncResultFilter.Decision
 
Constructor Summary
protected SimpleDelegatingDistributedTask()
           
  SimpleDelegatingDistributedTask(DistributedTask<T,R> task)
           
  SimpleDelegatingDistributedTask(DistributedTask<T,R> task, AsyncResultFilter<T> filter)
           
 
Method Summary
 R reduce(List<AsyncResult<T>> asyncResults)
           
 
Methods inherited from class org.openspaces.core.executor.support.AbstractDelegatingDistributedTask
_readExternal, _writeExternal, getFilter, onResult
 
Methods inherited from class org.openspaces.core.executor.support.SimpleDelegatingTask
execute, getDelegatedTask, getRouting
 
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
 

Constructor Detail

SimpleDelegatingDistributedTask

protected SimpleDelegatingDistributedTask()

SimpleDelegatingDistributedTask

public SimpleDelegatingDistributedTask(DistributedTask<T,R> task)

SimpleDelegatingDistributedTask

public SimpleDelegatingDistributedTask(DistributedTask<T,R> task,
                                       AsyncResultFilter<T> filter)
Method Detail

reduce

public R reduce(List<AsyncResult<T>> asyncResults)
         throws Exception
Throws:
Exception

GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.