public abstract class VisorOneNodeTask<A,R> extends VisorMultiNodeTask<A,R,R>
taskArg| Constructor and Description |
|---|
VisorOneNodeTask() |
| Modifier and Type | Method and Description |
|---|---|
R |
reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
job, map, result@Nullable public R reduce(List<GridComputeJobResult> results) throws GridException
GridComputeTaskFuture.get() method.
Note, that if some jobs did not succeed and could not be failed over then the list of results passed into this method will include the failed results. Otherwise, failed results will not be in the list.
results - Received results of broadcasted remote executions. Note that if task class has
GridComputeTaskNoResultCache annotation, then this list will be empty.GridException - If reduction or results caused an error. This exception will
be thrown out of GridComputeTaskFuture.get() method.Copyright © 2014. All rights reserved.