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

Constructors

Modifier	Constructor and Description
protected	SimpleDelegatingDistributedTask()
	SimpleDelegatingDistributedTask(DistributedTask<T,R> task)
	SimpleDelegatingDistributedTask(DistributedTask<T,R> task, AsyncResultFilter<T> filter)

Method Summary

Modifier and Type	Method and Description
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