| Package | Description |
|---|---|
| org.gridgain.grid.compute |
Contains Compute Grid functionality.
|
| org.gridgain.grid.kernal |
Contains main implementation.
|
| org.gridgain.grid.kernal.processors.job |
TODO.
|
| org.gridgain.grid.kernal.processors.session |
Session processing package to guarantee reuse of same session
object on the same node.
|
| Modifier and Type | Method and Description |
|---|---|
GridComputeJobSibling |
GridComputeTaskSession.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridComputeJobSibling> |
GridComputeTaskSession.getJobSiblings()
Gets a collection of all grid job siblings.
|
Collection<GridComputeJobSibling> |
GridComputeTaskSession.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 |
|---|---|
GridComputeJobSibling |
GridJobSessionImpl.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
GridComputeJobSibling |
GridTaskSessionImpl.getJobSibling(GridUuid jobId)
Gets job sibling for a given ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridComputeJobSibling> |
GridJobSessionImpl.getJobSiblings()
Gets a collection of all grid job siblings.
|
Collection<GridComputeJobSibling> |
GridTaskSessionImpl.getJobSiblings()
Gets a collection of all grid job siblings.
|
Collection<GridComputeJobSibling> |
GridJobExecuteRequest.getSiblings() |
Collection<GridComputeJobSibling> |
GridJobSiblingsResponse.jobSiblings() |
Collection<GridComputeJobSibling> |
GridJobSessionImpl.refreshJobSiblings()
Refreshes collection of job siblings.
|
Collection<GridComputeJobSibling> |
GridTaskSessionImpl.refreshJobSiblings()
Refreshes collection of job siblings.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTaskSessionImpl.addJobSiblings(Collection<GridComputeJobSibling> siblings) |
void |
GridTaskSessionImpl.setJobSiblings(Collection<GridComputeJobSibling> siblings) |
| Constructor and Description |
|---|
GridJobExecuteRequest(GridUuid sesId,
GridUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
GridComputeJob job,
long startTaskTime,
long timeout,
Collection<UUID> top,
byte[] siblingsBytes,
Collection<GridComputeJobSibling> siblings,
byte[] sesAttrsBytes,
Map<Object,Object> sesAttrs,
byte[] jobAttrsBytes,
Map<? extends Serializable,? extends Serializable> jobAttrs,
String cpSpi,
GridUuid clsLdrId,
GridDeploymentMode depMode,
boolean dynamicSiblings,
Map<UUID,GridUuid> ldrParticipants,
boolean forceLocDep,
boolean sesFullSup,
boolean internal) |
GridJobSiblingsResponse(Collection<GridComputeJobSibling> siblings,
byte[] siblingsBytes) |
GridTaskSessionImpl(UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
GridUuid sesId,
Collection<UUID> top,
long startTime,
long endTime,
Collection<GridComputeJobSibling> siblings,
Map<Object,Object> attrs,
GridKernalContext ctx,
boolean fullSup) |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridComputeJobSibling> |
GridJobProcessor.requestJobSiblings(GridComputeTaskSession ses) |
| Modifier and Type | Method and Description |
|---|---|
GridTaskSessionImpl |
GridTaskSessionProcessor.createTaskSession(GridUuid sesId,
UUID taskNodeId,
String taskName,
GridDeployment dep,
String taskClsName,
Collection<UUID> top,
long startTime,
long endTime,
Collection<GridComputeJobSibling> siblings,
Map<Object,Object> attrs,
boolean fullSup) |
Copyright © 2014. All rights reserved.