org.openspaces.core.executor.internal
Class InternalDistributedSpaceTaskWrapper<T extends Serializable,R>

java.lang.Object
  org.openspaces.core.executor.internal.InternalSpaceTaskWrapper<T>
      org.openspaces.core.executor.internal.InternalDistributedSpaceTaskWrapper<T,R>

All Implemented Interfaces:

com.gigaspaces.async.AsyncResultFilter<T>, com.gigaspaces.async.AsyncResultsReducer<T,R>, com.gigaspaces.executor.DistributedSpaceTask<T,R>, com.gigaspaces.executor.SpaceTask<T>, com.gigaspaces.executor.SpaceTaskWrapper, Externalizable, Serializable

public class InternalDistributedSpaceTaskWrapper<T extends Serializable,R>
extends InternalSpaceTaskWrapper<T>
implements com.gigaspaces.executor.DistributedSpaceTask<T,R>, com.gigaspaces.async.AsyncResultFilter<T>

An internal implemenation of DistributedSpaceTask that wraps the actual Task to be executed.

Author:

kimchy

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.gigaspaces.async.AsyncResultFilter

com.gigaspaces.async.AsyncResultFilter.Decision

Constructor Summary

InternalDistributedSpaceTaskWrapper()

InternalDistributedSpaceTaskWrapper(DistributedTask<T,R> task)

Method Summary

com.gigaspaces.async.AsyncResultFilter.Decision	onResult(com.gigaspaces.async.AsyncResultFilterEvent<T> event)
void	readExternal(ObjectInput in)
R	reduce(List<com.gigaspaces.async.AsyncResult<T>> asyncResults)
void	writeExternal(ObjectOutput out)

Methods inherited from class org.openspaces.core.executor.internal.InternalSpaceTaskWrapper

execute, getRouting, getTask, getWrappedTask, setRouting

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.gigaspaces.executor.SpaceTask

execute

Constructor Detail

InternalDistributedSpaceTaskWrapper

public InternalDistributedSpaceTaskWrapper()

InternalDistributedSpaceTaskWrapper

public InternalDistributedSpaceTaskWrapper(DistributedTask<T,R> task)

Method Detail

reduce

public R reduce(List<com.gigaspaces.async.AsyncResult<T>> asyncResults)
         throws Exception

Specified by:

reduce in interface com.gigaspaces.async.AsyncResultsReducer<T extends Serializable,R>

Throws:

Exception

onResult

public com.gigaspaces.async.AsyncResultFilter.Decision onResult(com.gigaspaces.async.AsyncResultFilterEvent<T> event)

Specified by:

onResult in interface com.gigaspaces.async.AsyncResultFilter<T extends Serializable>

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class InternalSpaceTaskWrapper<T extends Serializable>

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class InternalSpaceTaskWrapper<T extends Serializable>

Throws:

IOException

ClassNotFoundException