org.apache.ignite.internal.managers.failover

Class GridFailoverContextImpl

java.lang.Object

org.apache.ignite.internal.managers.failover.GridFailoverContextImpl

All Implemented Interfaces:

FailoverContext

public class GridFailoverContextImpl
extends Object
implements FailoverContext

GridFailoverContext implementation.

Constructor Summary

Constructors

Constructor and Description
GridFailoverContextImpl(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, GridLoadBalancerManager loadMgr, Object affKey, String affCacheName) Initializes failover context.

Method Summary

Methods

Modifier and Type	Method and Description
String	affinityCacheName() Returns affinity cache name IgniteCompute.affinityRun(String, Object, IgniteRunnable) and IgniteCompute.affinityCall(String, Object, IgniteCallable).
Object	affinityKey() Gets affinity key for IgniteCompute.affinityRun(String, Object, IgniteRunnable) and IgniteCompute.affinityCall(String, Object, IgniteCallable).
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.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GridFailoverContextImpl

public GridFailoverContextImpl(GridTaskSessionImpl taskSes,
                       ComputeJobResult jobRes,
                       GridLoadBalancerManager loadMgr,
                       @Nullable
                       Object affKey,
                       @Nullable
                       String affCacheName)

Initializes failover context.

Parameters:

taskSes - Grid task session.

jobRes - Failed job result.

loadMgr - Load manager.

affKey - Affinity key.

affCacheName - Affinity cache name.

Method Detail

getTaskSession

public ComputeTaskSession getTaskSession()

Gets current task session.

Specified by:

getTaskSession in interface FailoverContext

Returns:

Grid task session.

getJobResult

public ComputeJobResult getJobResult()

Gets failed result of job execution.

Specified by:

getJobResult in interface FailoverContext

Returns:

Result of a failed job.

getBalancedNode

public ClusterNode getBalancedNode(List<ClusterNode> top)

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.

Specified by:

getBalancedNode in interface FailoverContext

Parameters:

top - Topology to pick balanced node from.

Returns:

The next balanced node.

affinityKey

@Nullable
public Object affinityKey()

Gets affinity key for IgniteCompute.affinityRun(String, Object, IgniteRunnable) and IgniteCompute.affinityCall(String, Object, IgniteCallable).

Specified by:

affinityKey in interface FailoverContext

Returns:

Affinity key.

affinityCacheName

@Nullable
public String affinityCacheName()

Returns affinity cache name IgniteCompute.affinityRun(String, Object, IgniteRunnable) and IgniteCompute.affinityCall(String, Object, IgniteCallable).

Specified by:

affinityCacheName in interface FailoverContext

Returns:

Cache name.

toString

public String toString()

Overrides:

toString in class Object