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 Description GridFailoverContextImpl(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, GridLoadBalancerManager loadMgr, int partId, @Nullable String affCacheName, @Nullable AffinityTopologyVersion topVer)Initializes failover context.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description @Nullable StringaffinityCacheName()Returns affinity cache nameIgniteCompute.affinityRun(String, Object, IgniteRunnable)andIgniteCompute.affinityCall(String, Object, IgniteCallable).@Nullable AffinityTopologyVersionaffinityTopologyVersion()ClusterNodegetBalancedNode(List<ClusterNode> top)Gets the next balanced node for failed job.ComputeJobResultgetJobResult()Gets failed result of job execution.ComputeTaskSessiongetTaskSession()Gets current task session.intpartition()StringtoString()
-
-
-
Constructor Detail
-
GridFailoverContextImpl
public GridFailoverContextImpl(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, GridLoadBalancerManager loadMgr, int partId, @Nullable @Nullable String affCacheName, @Nullable @Nullable AffinityTopologyVersion topVer)
Initializes failover context.- Parameters:
taskSes- Grid task session.jobRes- Failed job result.loadMgr- Load manager.partId- Partition.affCacheName- Affinity cache name.topVer- Affinity topology version.
-
-
Method Detail
-
getTaskSession
public ComputeTaskSession getTaskSession()
Gets current task session.- Specified by:
getTaskSessionin interfaceFailoverContext- Returns:
- Grid task session.
-
getJobResult
public ComputeJobResult getJobResult()
Gets failed result of job execution.- Specified by:
getJobResultin interfaceFailoverContext- 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 (seeLoadBalancingSpito determine the optimal node for execution.- Specified by:
getBalancedNodein interfaceFailoverContext- Parameters:
top- Topology to pick balanced node from.- Returns:
- The next balanced node.
-
affinityCacheName
@Nullable public @Nullable String affinityCacheName()
Returns affinity cache nameIgniteCompute.affinityRun(String, Object, IgniteRunnable)andIgniteCompute.affinityCall(String, Object, IgniteCallable).- Specified by:
affinityCacheNamein interfaceFailoverContext- Returns:
- Cache name.
-
partition
public int partition()
Gets partition forIgniteCompute.affinityRun(Collection, int, IgniteRunnable)andIgniteCompute.affinityCall(Collection, int, IgniteCallable).- Specified by:
partitionin interfaceFailoverContext- Returns:
- Partition number.
-
affinityTopologyVersion
@Nullable public @Nullable AffinityTopologyVersion affinityTopologyVersion()
- Returns:
- Affinity topology version.
-
-