Apache Ignite.NET
Package Apache.Ignite.Core.Compute

Compute Grid functionality. More...

Classes

class  ComputeExecutionRejectedException
 Indicates a situation when execution service provided by the user in configuration rejects execution. More...
 
class  ComputeJobAdapter
 Convenience adapter for IComputeJob<T> implementations. It provides the following functionality: More...
 
class  ComputeJobFailoverException
 This runtime exception can be thrown from IComputeJob<T>.Execute() method to force job failover to another node within task topology. IComputeFunc<T,R> or IComputeFunc<T> passed into any of the ICompute methods can also throw this exception to force failover. More...
 
class  ComputeTaskAdapter
 Convenience adapter for IComputeTask<TArg,TJobRes,TTaskRes> interface More...
 
class  ComputeTaskCancelledException
 This exception indicates that Ignite task was cancelled. More...
 
class  ComputeTaskNoResultCacheAttribute
 This attribute disables caching of task results when attached to IComputeTask<A,T,R> instance. Use it when number of jobs within task grows too big, or jobs themselves are too large to keep in memory throughout task execution. By default all results are cached and passed into IComputeTask<TA,T,TR>.OnResult and IComputeTask<A,T,R>.Reduce methods. When this attribute is attached to a task class, then this list of job results will always be empty. More...
 
class  ComputeTaskSplitAdapter
 This class defines simplified adapter for IComputeTask<A,T,R>. This adapter can be used when jobs can be randomly assigned to available Ignite nodes. This adapter is sufficient in most homogeneous environments where all nodes are equally suitable for executing grid job, see Split method for more details. More...
 
class  ComputeTaskTimeoutException
 Indicates that task execution timed out. More...
 
class  ComputeUserUndeclaredException
 This exception is thrown when user's code throws undeclared runtime exception. By user core it is assumed the code in Ignite task, Ignite job or SPI. In most cases it should be an indication of unrecoverable error condition such as assertion, out of memory error, etc. More...
 
interface  ICompute
 Defines Ignite functionality for executing tasks and closures over nodes in the IClusterGroup. Instance of ICompute is obtained from grid projection using IClusterGroup.GetCompute method. More...
 
interface  IComputeAction
 Defines a void function having no arguments. More...
 
interface  IComputeFunc
 Defines function having a single argument. More...
 
interface  IComputeJob
 Defines executable unit for IComputeTask<A,T,R>. Ignite task gets split into jobs when IComputeTask<A,T,R>.Map(IList<IClusterNode>, A) method is called. This method returns all jobs for the task mapped to their corresponding Ignite nodes for execution. Grid will then serialize this jobs and send them to requested nodes for execution. More...
 
interface  IComputeJobResult
 Job execution result which gets passed to IComputeTask<TA,T,TR>.OnResult method. More...
 
interface  IComputeReducer
 Compute reducer which is capable of result collecting and reducing. More...
 
interface  IComputeTask
 Ignite task interface defines a task that can be executed on the grid. Ignite task is responsible for splitting business logic into multiple Ignite jobs, receiving results from individual Ignite jobs executing on remote nodes, and reducing (aggregating) received jobs' results into final Ignite task result. More...
 

Enumerations

enum  ComputeJobResultPolicy { ComputeJobResultPolicy.Wait = 0, ComputeJobResultPolicy.Reduce = 1, ComputeJobResultPolicy.Failover = 2 }
 This enumeration provides different types of actions following the last received job result. See IComputeTask<TA,T,TR>.OnResult for more details. More...
 

Detailed Description

Enumeration Type Documentation

Enumerator
Wait 

Wait for results if any are still expected. If all results have been received - it will start reducing results.

Reduce 

Ignore all not yet received results and start reducing results.

Failover 

Fail-over job to execute on another node.