org.apache.ignite.spi.failover

Interface FailoverContext

public interface FailoverContext

This interface defines a set of operations available to failover SPI one a given failed job.

Method Summary

Modifier and Type	Method and Description
String	affinityCacheName() Returns affinity cache name if the task was launched using IgniteCompute.affinityRun(String, Object, IgniteRunnable) or IgniteCompute.affinityCall(String, Object, IgniteCallable) calls.
ClusterNode	getBalancedNode(List<ClusterNode> top) Gets the next balanced node for failed job.
ComputeJobResult	getJobResult() Gets failed result of job execution.
ComputeTaskSession	getTaskSession() Gets current task session.
int	partition() Gets partition for IgniteCompute.affinityRun(Collection, int, IgniteRunnable) and IgniteCompute.affinityCall(Collection, int, IgniteCallable).

Method Detail

getTaskSession

ComputeTaskSession getTaskSession()

Gets current task session.

Returns:

Grid task session.

getJobResult

ComputeJobResult getJobResult()

Gets failed result of job execution.

Returns:

Result of a failed job.

getBalancedNode

ClusterNode getBalancedNode(List<ClusterNode> top)
                     throws IgniteException

Gets the next balanced node for failed job. Internally this method will delegate to load balancing SPI (see LoadBalancingSpi to determine the optimal node for execution.

Parameters:

top - Topology to pick balanced node from.

Returns:

The next balanced node.

Throws:

IgniteException - If anything failed.

partition

int partition()

Gets partition for IgniteCompute.affinityRun(Collection, int, IgniteRunnable) and IgniteCompute.affinityCall(Collection, int, IgniteCallable).

Returns:

Partition number.

affinityCacheName

String affinityCacheName()

Returns affinity cache name if the task was launched using IgniteCompute.affinityRun(String, Object, IgniteRunnable) or IgniteCompute.affinityCall(String, Object, IgniteCallable) calls.

Returns:

Cache name or null if task was not an partition-aware task.