|
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...
|
|