public interface ComputeJobResult
|Modifier and Type||Method and Description|
Gets data returned by remote job if it didn't fail.
Gets exception produced by execution of remote job, or
Gets local instance of remote job returned by
Gets job context.
Gets node this job executed on.
Gets job cancellation status.
<T> T getData()
Note that if task is annotated with
then job results will not be cached and will be available only in
ComputeTask.result(ComputeJobResult, List) method for every individual job,
but not in
ComputeTask.reduce(List) method. This feature was added to
avoid excessive storing of overly large results.
nullif remote execution finished normally and did not produce any exceptions.
IgniteExceptionproduced by execution of remote job or
nullif no exception was produced.
If job on remote node was rejected (cancelled while it was on waiting queue), then
ComputeExecutionRejectedException will be returned.
If node on which job was computing failed, then
<T extends ComputeJob> T getJob()
trueif job received cancellation request on remote node. Note that job, after receiving cancellation request, will still need to finish and return, hence
getData()method may contain execution result even if the job was canceled.
Job can receive cancellation request if the task was explicitly cancelled
from future (see
IgniteFuture.cancel()) or if task completed prior
to getting results from all remote jobs.
trueif job received cancellation request and