| Package | Description |
|---|---|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.managers.failover |
TODO.
|
| org.apache.ignite.internal.managers.loadbalancer |
TODO.
|
| org.apache.ignite.internal.processors.resource |
TODO.
|
| org.apache.ignite.internal.processors.session |
Session processing package to guarantee reuse of same session
object on the same node.
|
| org.apache.ignite.internal.processors.task |
TODO.
|
| Constructor and Description |
|---|
GridJobSessionImpl(GridKernalContext ctx,
GridTaskSessionImpl ses,
IgniteUuid jobId) |
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
List<ClusterNode> top,
int affPartId,
Object affKey,
String affCacheName,
AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridFailoverContextImpl(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
GridLoadBalancerManager loadMgr,
int partId,
Object affKey,
String affCacheName,
AffinityTopologyVersion topVer)
Initializes failover context.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<ClusterNode> top,
ComputeJob job) |
ComputeLoadBalancer |
GridLoadBalancerManager.getLoadBalancer(GridTaskSessionImpl ses,
List<ClusterNode> top) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridResourceProcessor.inject(GridDeployment dep,
ComputeTask<?,?> task,
GridTaskSessionImpl ses,
ComputeLoadBalancer balancer,
ComputeTaskContinuousMapper mapper)
Injects held resources into given grid task.
|
| Modifier and Type | Method and Description |
|---|---|
GridTaskSessionImpl |
GridTaskSessionProcessor.createTaskSession(IgniteUuid sesId,
UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
Collection<UUID> top,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
boolean fullSup,
boolean internal,
UUID subjId) |
GridTaskSessionImpl |
GridTaskSessionProcessor.getSession(IgniteUuid sesId) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskProcessor.setAttributes(GridTaskSessionImpl ses,
Map<?,?> attrs) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.8.0 Release Date : December 5 2016