Convenience adapter for IComputeTask<TArg,TJobRes,TTaskRes> interface
More...
|
virtual ComputeJobResultPolicy | OnResult (IComputeJobResult< TJobRes > res, IList< IComputeJobResult< TJobRes >> rcvd) |
| Default implementation which will wait for all jobs to complete before calling IComputeTask<A,T,R>.Reduce method. If remote job resulted in exception IComputeJobResult<T>.Exception() is not null ), then ComputeJobResultPolicy.Failover policy will be returned if the exception is instance of ClusterTopologyException or 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. More...
|
|
abstract IDictionary< IComputeJob< TJobRes >, IClusterNode > | Map (IList< IClusterNode > subgrid, TArg arg) |
| This method is called to map or split Ignite task into multiple Ignite jobs. This is the first method that gets called when task execution starts. More...
|
|
abstract TTaskRes | Reduce (IList< IComputeJobResult< TJobRes >> results) |
| Reduces (or aggregates) results received so far into one compound result to be returned to caller via task. More...
|
|
- Parameters
-
subgrid | Nodes available for this task execution. Note that order of nodes is guaranteed to be randomized by container. This ensures that every time you simply iterate through Ignite nodes, the order of nodes will be random which over time should result into all nodes being used equally. |
arg | Task execution argument. Can be null . This is the same argument as the one passed into ICompute.Execute() methods. |
- Returns
- Map of Ignite jobs assigned to subgrid node. If
null
or empty map is returned, exception will be thrown.
Implemented in Apache.Ignite.Core.Compute.ComputeTaskSplitAdapter< TArg, TJobRes, TTaskRes >.
- Parameters
-
res | Received remote Ignite executable result. |
rcvd | All previously received results. |
- Returns
- Result policy that dictates how to process further upcoming job results.
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.
- Parameters
-
- Returns
- Task result constructed from results of remote executions.