Apache Ignite.NET
|
Convenience adapter for IComputeTask<TArg,TJobRes,TTaskRes> interface More...
Public Member Functions | |
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... | |
|
pure virtual |
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. |
null
or empty map is returned, exception will be thrown. Implemented in Apache.Ignite.Core.Compute.ComputeTaskSplitAdapter< TArg, TJobRes, TTaskRes >.
|
virtual |
res | Received remote Ignite executable result. |
rcvd | All previously received results. |
|
pure virtual |
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 job results. Note that if task class has ComputeTaskNoResultCacheAttribute attribute, then this list will be empty. |