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 implementation 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