| Modifier and Type | Class and Description |
|---|---|
class |
GridComputeJobAdapter
Convenience adapter for
GridComputeJob implementations. |
class |
GridComputeJobContinuationAdapter
Convenience adapter for
GridComputeJob implementations. |
| Modifier and Type | Method and Description |
|---|---|
<T extends GridComputeJob> |
GridComputeJobResult.getJob()
Gets local instance of remote job returned by
GridComputeTask.map(List, Object) method. |
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridComputeTaskSplitAdapter.map(List<GridNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridComputeTask.map(List<GridNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
protected abstract Collection<? extends GridComputeJob> |
GridComputeTaskSplitAdapter.split(int gridSize,
T arg)
This is a simplified version of
GridComputeTask.map(List, Object) method. |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridComputeLoadBalancer.getBalancedNode(GridComputeJob job,
Collection<GridNode> exclNodes)
Gets the next balanced node according to the underlying load balancing policy.
|
void |
GridComputeTaskContinuousMapper.send(GridComputeJob job)
Sends job to a node automatically picked by the underlying load balancer.
|
void |
GridComputeTaskContinuousMapper.send(GridComputeJob job,
GridNode node)
Sends given job to a specific grid node.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridComputeTaskContinuousMapper.send(Collection<? extends GridComputeJob> jobs)
Sends collection of jobs to nodes automatically picked by the underlying load balancer.
|
void |
GridComputeTaskContinuousMapper.send(Map<? extends GridComputeJob,GridNode> mappedJobs)
Sends collection of grid jobs to assigned nodes.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridifyDefaultTask.map(List<GridNode> subgrid,
GridifyArgument arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridifyDefaultRangeTask.map(List<GridNode> subgrid,
GridifyRangeArgument arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridGgfsTask.map(List<GridNode> subgrid,
GridGgfsTaskArgs<T> args)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
GridComputeJob |
GridJobExecuteRequest.getJob() |
GridComputeJob |
GridJobResultImpl.getJob()
Gets local instance of remote job returned by
GridComputeTask.map(List, Object) method. |
| 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) |
GridJobResultImpl(GridComputeJob job,
GridUuid jobId,
GridNode node,
GridJobSiblingImpl sib) |
| Modifier and Type | Method and Description |
|---|---|
GridComputeJob |
GridCollisionJobContextAdapter.getJob()
Job for this context.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<GridNode> top,
GridComputeJob job) |
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridCacheQueryJdbcTask.map(List<GridNode> subgrid,
byte[] arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridCacheQueryJdbcMetadataTask.map(List<GridNode> subgrid,
String cacheName)
This method is called to map or split grid task into multiple grid jobs.
|
protected Collection<? extends GridComputeJob> |
GridCacheQueryJdbcValidationTask.split(int gridSize,
String cacheName)
This is a simplified version of
GridComputeTask.map(List, Object) method. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridMasterLeaveAwareComputeJobAdapter
Job adapter implementing
GridComputeJobMasterLeaveAware. |
| Modifier and Type | Method and Description |
|---|---|
GridComputeJob |
GridNoopGgfsProcessor.createJob(GridGgfsJob job,
String ggfsName,
GridGgfsPath path,
long start,
long length,
GridGgfsRecordResolver recRslv)
Create compute job for the given GGFS job.
|
abstract GridComputeJob |
GridGgfsProcessorAdapter.createJob(GridGgfsJob job,
String ggfsName,
GridGgfsPath path,
long start,
long length,
GridGgfsRecordResolver recRslv)
Create compute job for the given GGFS job.
|
| Modifier and Type | Method and Description |
|---|---|
GridComputeJob |
GridJobWorker.getJob()
Gets deployed job or
null of job could not be deployed. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridResourceProcessor.inject(GridDeployment dep,
Class<?> taskCls,
GridComputeJob job,
GridComputeTaskSession ses,
GridJobContextImpl jobCtx)
Injects held resources into given
job. |
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridStreamerReduceTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridStreamerBroadcastTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridStreamerQueryTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorJob<A,R>
Base class for Visor jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
VisorMultiNodeTask.map(List<GridNode> subgrid,
GridBiTuple<Set<UUID>,A> arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
GridComputeJob |
GridCollisionJobContext.getJob()
Job for this context.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridAdaptiveLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridRoundRobinLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridWeightedRandomLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridifyJobAdapter
Convenience adapter for custom
gridify jobs. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridComputeJobWrapper
Convenient wrapper for grid job.
|
| Modifier and Type | Method and Description |
|---|---|
GridComputeJob |
GridComputeJobWrapper.wrappedJob()
Gets wrapped job.
|
| Constructor and Description |
|---|
GridComputeJobWrapper(GridComputeJob job,
boolean cpMeta)
Creates a wrapper with given grid
job. |
Copyright © 2014. All rights reserved.