Package org.apache.ignite.compute

Contains Compute Grid functionality.

Interface Summary

Interface	Description
ComputeJob	Defines executable unit for ComputeTask.
ComputeJobContext	Context attached to every job executed on the grid.
ComputeJobContinuation	Defines continuation support for grid job context.
ComputeJobMasterLeaveAware	Annotation for handling master node leave during job execution.
ComputeJobResult	Result of remote job which gets passed into ComputeTask.result(ComputeJobResult, List) method.
ComputeJobSibling	Job sibling interface defines a job from the same split.
ComputeLoadBalancer	Load balancer is used for finding the best balanced node according to load balancing policy.
ComputeTask<T,R>	Grid task interface defines a task that can be executed on the grid.
ComputeTaskContinuousMapper	Defines a mapper that can be used for asynchronous job sending.
ComputeTaskFuture<R>	This class defines a handler for asynchronous task execution.
ComputeTaskSession	Defines a distributed session for particular task execution.
ComputeTaskSessionAttributeListener	This interface defines listener for task session attributes.

Class Summary

Class	Description
ComputeJobAdapter	Convenience adapter for ComputeJob implementations.
ComputeJobContinuationAdapter	Convenience adapter for ComputeJob implementations.
ComputeTaskAdapter<T,R>	Convenience adapter for ComputeTask interface.
ComputeTaskSplitAdapter<T,R>	This class defines simplified adapter for ComputeTask.

Enum Summary

Enum	Description
ComputeJobResultPolicy	This enumeration provides different types of actions following the last received job result.
ComputeTaskSessionScope	Defines life-time scopes for checkpoint operations.

Exception Summary

Exception	Description
ComputeExecutionRejectedException	This exception defines execution rejection.
ComputeJobFailoverException	This runtime exception can be thrown from ComputeJob.execute() method to force job failover to another node within task topology.
ComputeTaskCancelledException	This exception indicates that grid task was cancelled.
ComputeTaskTimeoutException	This exception indicates that task execution timed out.
ComputeUserUndeclaredException	This exception is thrown when user's code throws undeclared runtime exception.

Annotation Types Summary

Annotation Type	Description
ComputeJobAfterSend	This annotation allows to call a method right after the job has been successfully sent for execution.
ComputeJobBeforeFailover	This annotation allows to call a method right before job is submitted to FailoverSpi.
ComputeTaskMapAsync	Annotation for asynchronous task mapping.
ComputeTaskName	This annotation allows to assign optional name to grid task.
ComputeTaskNoResultCache	This annotation disables caching of task results when attached to ComputeTask class being executed.
ComputeTaskSessionFullSupport	Annotation for enabling task session attributes and checkpoints for tasks.
ComputeTaskSpis	This annotation allows task to specify what SPIs it wants to use.