|Modifier and Type||Method and Description|
This method is called to map or split grid task into multiple grid jobs.
Reduces (or aggregates) results received so far into one compound result to be returned to caller via
Default implementation which will wait for all jobs to complete before calling
public FitnessTask(GAConfiguration cfg)
public Map map(List<ClusterNode> nodes, List<Long> chromosomeKeys) throws IgniteException
public Boolean reduce(List<ComputeJobResult> list) throws IgniteException
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.
public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd)
If remote job resulted in exception (
ComputeJobResult.getException() is not
ComputeJobResultPolicy.FAILOVER policy will be returned if the exception is instance
ComputeExecutionRejectedException, which means that
remote node either failed or job execution was rejected before it got a chance to start. In all
other cases the exception will be rethrown which will ultimately cause task to fail.