public class InternalDistributedSpaceTaskWrapper<T extends Serializable,R> extends InternalSpaceTaskWrapper<T> implements DistributedSpaceTask<T,R>, AsyncResultFilter<T>
DistributedSpaceTask that wraps the
actual Task to be executed.AsyncResultFilter.Decision| Constructor and Description |
|---|
InternalDistributedSpaceTaskWrapper() |
InternalDistributedSpaceTaskWrapper(DistributedTask<T,R> task) |
| Modifier and Type | Method and Description |
|---|---|
AsyncResultFilter.Decision |
onResult(AsyncResultFilterEvent<T> event)
A callback invoked for each result that arrives as a result of a distributed task execution
allowing to access the result that caused this event, the events received so far, and the
total expected results.
|
void |
readExternal(ObjectInput in) |
R |
reduce(List<AsyncResult<T>> asyncResults) |
void |
writeExternal(ObjectOutput out) |
execute, getRouting, getSupportCodeChangeAnnotationContainer, getTask, getWrappedTask, setRoutingclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitenabledSmartExternalizableWithReferencepublic InternalDistributedSpaceTaskWrapper()
public InternalDistributedSpaceTaskWrapper(DistributedTask<T,R> task)
public R reduce(List<AsyncResult<T>> asyncResults) throws Exception
reduce in interface AsyncResultsReducer<T extends Serializable,R>Exceptionpublic AsyncResultFilter.Decision onResult(AsyncResultFilterEvent<T> event)
AsyncResultFilteronResult in interface AsyncResultFilter<T extends Serializable>public void writeExternal(ObjectOutput out) throws IOException
writeExternal in interface ExternalizablewriteExternal in class InternalSpaceTaskWrapper<T extends Serializable>IOExceptionpublic void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal in interface ExternalizablereadExternal in class InternalSpaceTaskWrapper<T extends Serializable>IOExceptionClassNotFoundExceptionCopyright © GigaSpaces.