| Modifier and Type | Class and Description |
|---|---|
class |
ComputeJobAdapter
Convenience adapter for
ComputeJob implementations. |
class |
ComputeJobContinuationAdapter
Convenience adapter for
ComputeJob implementations. |
| Modifier and Type | Method and Description |
|---|---|
<T extends ComputeJob> |
ComputeJobResult.getJob()
Gets local instance of remote job returned by
ComputeTask.map(List, Object) method. |
| Modifier and Type | Method and Description |
|---|---|
protected abstract Collection<? extends ComputeJob> |
ComputeTaskSplitAdapter.split(int gridSize,
T arg)
This is a simplified version of
ComputeTask.map(List, Object) method. |
| Modifier and Type | Method and Description |
|---|---|
@Nullable ClusterNode |
ComputeLoadBalancer.getBalancedNode(ComputeJob job,
@Nullable Collection<ClusterNode> exclNodes)
Gets the next balanced node according to the underlying load balancing policy.
|
void |
ComputeTaskContinuousMapper.send(ComputeJob job)
Sends job to a node automatically picked by the underlying load balancer.
|
void |
ComputeTaskContinuousMapper.send(ComputeJob job,
ClusterNode node)
Sends given job to a specific grid node.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ComputeTaskContinuousMapper.send(Collection<? extends ComputeJob> jobs)
Sends collection of jobs to nodes automatically picked by the underlying load balancer.
|
void |
ComputeTaskContinuousMapper.send(Map<? extends ComputeJob,ClusterNode> mappedJobs)
Sends collection of grid jobs to assigned nodes.
|
| Modifier and Type | Method and Description |
|---|---|
ComputeJob |
GridJobExecuteRequest.getJob() |
ComputeJob |
GridJobResultImpl.getJob()
Gets local instance of remote job returned by
ComputeTask.map(List, Object) method. |
| Constructor and Description |
|---|
GridJobExecuteRequest(IgniteUuid sesId,
IgniteUuid jobId,
String taskName,
String userVer,
String taskClsName,
byte[] jobBytes,
ComputeJob job,
long startTaskTime,
long timeout,
@Nullable Collection<UUID> top,
@Nullable IgnitePredicate<ClusterNode> topPred,
byte[] topPredBytes,
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,
@Nullable int[] cacheIds,
int part,
@Nullable AffinityTopologyVersion topVer,
@Nullable String execName) |
GridJobResultImpl(ComputeJob job,
IgniteUuid jobId,
ClusterNode node,
GridJobSiblingImpl sib) |
| Modifier and Type | Method and Description |
|---|---|
protected Collection<? extends ComputeJob> |
JdbcConnectionValidationTask.split(int gridSize,
Object arg)
Deprecated.
This is a simplified version of
ComputeTask.map(List, Object) method. |
| Modifier and Type | Method and Description |
|---|---|
ComputeJob |
GridCollisionJobContextAdapter.getJob()
Job for this context.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<ClusterNode> top,
ComputeJob job) |
| Modifier and Type | Class and Description |
|---|---|
static class |
GridCacheAdapter.TopologyVersionAwareJob
Delayed callable class.
|
| Modifier and Type | Class and Description |
|---|---|
static class |
GridDistributedCacheAdapter.GlobalRemoveAllJob<K,V>
Internal job which performs remove all primary key mappings
operation on a cache with the given name.
|
| Modifier and Type | Method and Description |
|---|---|
protected Collection<? extends ComputeJob> |
GridCacheQueryJdbcValidationTask.split(int gridSize,
@Nullable String cacheName)
This is a simplified version of
ComputeTask.map(List, Object) method. |
| Modifier and Type | Class and Description |
|---|---|
static class |
CollectConflictPartitionKeysTask.CollectPartitionEntryHashesJob |
static class |
RetrieveConflictPartitionValuesTask.RetrieveConflictValuesJob |
| Modifier and Type | Class and Description |
|---|---|
static class |
GridClosureProcessor.C1<T,R> |
static class |
GridClosureProcessor.C1MLA<T,R> |
static class |
GridClosureProcessor.C2<R> |
static class |
GridClosureProcessor.C2MLA<R> |
static class |
GridClosureProcessor.C4 |
static class |
GridClosureProcessor.C4MLA |
| Modifier and Type | Method and Description |
|---|---|
@Nullable ComputeJob |
GridJobWorker.getJob()
Gets deployed job or
null of job could not be deployed. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
PlatformJob
Platform closure job interface.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformAbstractJob
Base interop job.
|
class |
PlatformClosureJob
Light-weight interop job.
|
class |
PlatformFullJob
Wrapper around job created in native platform.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridResourceProcessor.inject(GridDeployment dep,
Class<?> taskCls,
ComputeJob job,
ComputeTaskSession ses,
GridJobContextImpl jobCtx)
Injects held resources into given
job. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridifyJobAdapter
Convenience adapter for custom
gridify jobs. |
| Modifier and Type | Class and Description |
|---|---|
class |
VisorJob<A,R>
Base class for Visor jobs.
|
| Modifier and Type | Method and Description |
|---|---|
protected Map<? extends ComputeJob,ClusterNode> |
VisorMultiNodeTask.map0(List<ClusterNode> subgrid,
VisorTaskArgument<A> arg)
Actual map logic.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorCacheConfigurationCollectorJob
Job that collect cache configuration from node.
|
| Modifier and Type | Class and Description |
|---|---|
protected static class |
VisorCacheGroupEncryptionTask.VisorReencryptionBaseJob<T> |
| Modifier and Type | Class and Description |
|---|---|
class |
VisorNodeConfigurationCollectorJob
Grid configuration data collect job.
|
class |
VisorNodeDataCollectorJob
Job that collects data from node.
|
protected static class |
VisorNodeEventsCollectorTask.VisorNodeEventsCollectorJob
Job for task returns events data.
|
| Modifier and Type | Method and Description |
|---|---|
protected Map<? extends ComputeJob,ClusterNode> |
VisorQueryCleanupTask.map0(List<ClusterNode> subgrid,
@Nullable VisorTaskArgument<VisorQueryCleanupTaskArg> arg)
Actual map logic.
|
| Modifier and Type | Method and Description |
|---|---|
ComputeJob |
CollisionJobContext.getJob()
Job for this context.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
LoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
AdaptiveLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
RoundRobinLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
WeightedRandomLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021