public interface FailoverContext
| 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()
|
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.
|
ComputeTaskSession getTaskSession()
ComputeJobResult getJobResult()
ClusterNode getBalancedNode(List<ClusterNode> top) throws IgniteException
LoadBalancingSpi to
determine the optimal node for execution.top - Topology to pick balanced node from.IgniteException - If anything failed.@Nullable Object affinityKey()
IgniteCompute.affinityRun(String, Object, IgniteRunnable)
and IgniteCompute.affinityCall(String, Object, IgniteCallable).@Nullable String affinityCacheName()
IgniteCompute.affinityRun(String, Object, IgniteRunnable)
and IgniteCompute.affinityCall(String, Object, IgniteCallable).
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016