| Package | Description |
|---|---|
| org.apache.ignite.compute |
Contains Compute Grid functionality.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.job |
TODO.
|
| org.apache.ignite.internal.processors.session |
Session processing package to guarantee reuse of same session
object on the same node.
|
| Modifier and Type | Method and Description |
|---|---|
ComputeJobSibling |
ComputeTaskSession.getJobSibling(IgniteUuid jobId)
Gets job sibling for a given ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ComputeJobSibling> |
ComputeTaskSession.getJobSiblings()
Gets a collection of all grid job siblings.
|
Collection<ComputeJobSibling> |
ComputeTaskSession.refreshJobSiblings()
Refreshes collection of job siblings.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridJobSiblingImpl
This class provides implementation for job sibling.
|
| Modifier and Type | Method and Description |
|---|---|
ComputeJobSibling |
GridJobSessionImpl.getJobSibling(IgniteUuid jobId)
Gets job sibling for a given ID.
|
ComputeJobSibling |
GridTaskSessionImpl.getJobSibling(IgniteUuid jobId)
Gets job sibling for a given ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<ComputeJobSibling> |
GridJobSessionImpl.getJobSiblings()
Gets a collection of all grid job siblings.
|
Collection<ComputeJobSibling> |
GridTaskSessionImpl.getJobSiblings()
Gets a collection of all grid job siblings.
|
Collection<ComputeJobSibling> |
GridJobExecuteRequest.getSiblings() |
Collection<ComputeJobSibling> |
GridJobSiblingsResponse.jobSiblings() |
Collection<ComputeJobSibling> |
GridJobSessionImpl.refreshJobSiblings()
Refreshes collection of job siblings.
|
Collection<ComputeJobSibling> |
GridTaskSessionImpl.refreshJobSiblings()
Refreshes collection of job siblings.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskSessionImpl.addJobSiblings(Collection<ComputeJobSibling> siblings) |
void |
GridTaskSessionImpl.setJobSiblings(Collection<ComputeJobSibling> siblings) |
| Constructor and Description |
|---|
GridJobExecuteRequest(IgniteUuid sesId,
IgniteUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
ComputeJob job,
long startTaskTime,
long timeout,
Collection<UUID> top,
byte[] siblingsBytes,
Collection<ComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
IgniteUuid clsLdrId,
DeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,IgniteUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal,
UUID subjId,
int[] cacheIds,
int part,
AffinityTopologyVersion topVer) |
GridJobSiblingsResponse(Collection<ComputeJobSibling> siblings,
byte[] siblingsBytes) |
GridTaskSessionImpl(UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
IgniteUuid sesId,
Collection<UUID> top,
long startTime,
long endTime,
Collection<ComputeJobSibling> siblings,
Map<Object,Object> attrs,
GridKernalContext ctx,
boolean fullSup,
boolean internal,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
Collection<ComputeJobSibling> |
GridJobProcessor.requestJobSiblings(ComputeTaskSession ses) |
| 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) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.8.0 Release Date : December 5 2016