Uses of Interface
org.apache.ignite.compute.ComputeJob

Packages that use ComputeJob

Package	Description
org.apache.ignite.compute	Contains Compute Grid functionality.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.management.cache
org.apache.ignite.internal.management.encryption
org.apache.ignite.internal.management.snapshot
org.apache.ignite.internal.management.tx
org.apache.ignite.internal.managers.collision	TODO.
org.apache.ignite.internal.managers.loadbalancer	TODO.
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.persistence.snapshot
org.apache.ignite.internal.processors.cache.verify
org.apache.ignite.internal.processors.closure	TODO.
org.apache.ignite.internal.processors.job	TODO.
org.apache.ignite.internal.processors.platform.compute
org.apache.ignite.internal.processors.resource	TODO.
org.apache.ignite.internal.util.future	Future related classes.
org.apache.ignite.internal.visor
org.apache.ignite.spi.collision	Contains APIs for collision SPI.
org.apache.ignite.spi.loadbalancing	Contains APIs for load balancing SPI.
org.apache.ignite.spi.loadbalancing.adaptive	Contains adaptive load balancing SPI.
org.apache.ignite.spi.loadbalancing.roundrobin	Contains default round-robin implementation for load balancing SPI.
org.apache.ignite.spi.loadbalancing.weightedrandom	Contains weighted random-base implementation for load balancing SPI.

Uses of ComputeJob in org.apache.ignite.compute

Classes in org.apache.ignite.compute that implement ComputeJob

Modifier and Type	Class	Description
class	ComputeJobAdapter	Convenience adapter for ComputeJob implementations.
class	ComputeJobContinuationAdapter	Convenience adapter for ComputeJob implementations.

Methods in org.apache.ignite.compute with type parameters of type ComputeJob

Modifier and Type	Method	Description
<T extends ComputeJob> T	ComputeJobResult.getJob()	Gets local instance of remote job returned by ComputeTask.map(List, Object) method.

Methods in org.apache.ignite.compute that return types with arguments of type ComputeJob

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	ComputeTask.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	ComputeTaskSplitAdapter.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.
protected abstract Collection<? extends ComputeJob>	ComputeTaskSplitAdapter.split(int gridSize, T arg)	This is a simplified version of ComputeTask.map(List, Object) method.

Methods in org.apache.ignite.compute with parameters of type ComputeJob

Modifier and Type	Method	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.

Method parameters in org.apache.ignite.compute with type arguments of type ComputeJob

Modifier and Type	Method	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.

Uses of ComputeJob in org.apache.ignite.internal

Methods in org.apache.ignite.internal that return ComputeJob

Modifier and Type	Method	Description
ComputeJob	GridJobExecuteRequest.getJob()
ComputeJob	GridJobResultImpl.getJob()	Gets local instance of remote job returned by ComputeTask.map(List, Object) method.

Constructors in org.apache.ignite.internal with parameters of type ComputeJob

Constructor	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, @org.jetbrains.annotations.Nullable int[] cacheIds, int part, @Nullable AffinityTopologyVersion topVer, @Nullable String execName)
GridJobResultImpl(ComputeJob job, IgniteUuid jobId, ClusterNode node, GridJobSiblingImpl sib)

Uses of ComputeJob in org.apache.ignite.internal.management.cache

Classes in org.apache.ignite.internal.management.cache that implement ComputeJob

Modifier and Type	Class	Description
class	CacheConfigurationCollectorJob	Job that collect cache configuration from node.

Methods in org.apache.ignite.internal.management.cache that return types with arguments of type ComputeJob

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	VerifyBackupPartitionsDumpTask.map(List<ClusterNode> subgrid, CacheIdleVerifyCommandArg arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	VerifyBackupPartitionsTaskV2.map(List<ClusterNode> subgrid, CacheIdleVerifyCommandArg arg)	This method is called to map or split grid task into multiple grid jobs.

Uses of ComputeJob in org.apache.ignite.internal.management.encryption

Classes in org.apache.ignite.internal.management.encryption that implement ComputeJob

Modifier and Type	Class	Description
protected static class	CacheGroupEncryptionTask.ReencryptionBaseJob<T>

Uses of ComputeJob in org.apache.ignite.internal.management.snapshot

Classes in org.apache.ignite.internal.management.snapshot that implement ComputeJob

Modifier and Type	Class	Description
class	SnapshotJob<A,R>

Uses of ComputeJob in org.apache.ignite.internal.management.tx

Classes in org.apache.ignite.internal.management.tx that implement ComputeJob

Modifier and Type	Class	Description
static class	TxTask.TxJob

Uses of ComputeJob in org.apache.ignite.internal.managers.collision

Methods in org.apache.ignite.internal.managers.collision that return ComputeJob

Modifier and Type	Method	Description
ComputeJob	GridCollisionJobContextAdapter.getJob()	Job for this context.

Uses of ComputeJob in org.apache.ignite.internal.managers.loadbalancer

Methods in org.apache.ignite.internal.managers.loadbalancer with parameters of type ComputeJob

Modifier and Type	Method	Description
ClusterNode	GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses, List<ClusterNode> top, ComputeJob job)

Uses of ComputeJob in org.apache.ignite.internal.processors.cache

Classes in org.apache.ignite.internal.processors.cache that implement ComputeJob

Modifier and Type	Class	Description
static class	GridCacheAdapter.TopologyVersionAwareJob	Delayed callable class.

Uses of ComputeJob in org.apache.ignite.internal.processors.cache.distributed

Classes in org.apache.ignite.internal.processors.cache.distributed that implement ComputeJob

Modifier and Type	Class	Description
static class	GridDistributedCacheAdapter.GlobalRemoveAllJob<K,V>	Internal job which performs remove all primary key mappings operation on a cache with the given name.

Uses of ComputeJob in org.apache.ignite.internal.processors.cache.persistence.snapshot

Classes in org.apache.ignite.internal.processors.cache.persistence.snapshot that implement ComputeJob

Modifier and Type	Class	Description
protected static class	AbstractSnapshotVerificationTask.AbstractSnapshotVerificationJob

Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot that return types with arguments of type ComputeJob

Modifier and Type	Method	Description
Map<ComputeJob,ClusterNode>	AbstractSnapshotVerificationTask.map(List<ClusterNode> subgrid, SnapshotPartitionsVerifyTaskArg arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	SnapshotMetadataVerificationTask.map(List<ClusterNode> subgrid, SnapshotMetadataVerificationTaskArg arg)	This method is called to map or split grid task into multiple grid jobs.

Uses of ComputeJob in org.apache.ignite.internal.processors.cache.verify

Classes in org.apache.ignite.internal.processors.cache.verify that implement ComputeJob

Modifier and Type	Class	Description
static class	CollectConflictPartitionKeysTask.CollectPartitionEntryHashesJob
static class	RetrieveConflictPartitionValuesTask.RetrieveConflictValuesJob

Methods in org.apache.ignite.internal.processors.cache.verify that return types with arguments of type ComputeJob

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	CollectConflictPartitionKeysTask.map(List<ClusterNode> subgrid, PartitionKey partKey)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	RetrieveConflictPartitionValuesTask.map(List<ClusterNode> subgrid, Map<PartitionHashRecord,List<PartitionEntryHashRecord>> collectTaskRes)	This method is called to map or split grid task into multiple grid jobs.

Uses of ComputeJob in org.apache.ignite.internal.processors.closure

Classes in org.apache.ignite.internal.processors.closure that implement ComputeJob

Modifier and Type	Class	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

Uses of ComputeJob in org.apache.ignite.internal.processors.job

Methods in org.apache.ignite.internal.processors.job that return ComputeJob

Modifier and Type	Method	Description
@Nullable ComputeJob	GridJobWorker.getJob()	Gets deployed job or null of job could not be deployed.

Uses of ComputeJob in org.apache.ignite.internal.processors.platform.compute

Subinterfaces of ComputeJob in org.apache.ignite.internal.processors.platform.compute

Modifier and Type	Interface	Description
interface	PlatformJob	Platform closure job interface.

Classes in org.apache.ignite.internal.processors.platform.compute that implement ComputeJob

Modifier and Type	Class	Description
class	PlatformAbstractJob	Base interop job.
class	PlatformClosureJob	Light-weight interop job.
class	PlatformFullJob	Wrapper around job created in native platform.

Methods in org.apache.ignite.internal.processors.platform.compute that return types with arguments of type ComputeJob

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBalancingMultiClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBalancingSingleClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBroadcastingMultiClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformBroadcastingSingleClosureTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.
@NotNull Map<? extends ComputeJob,ClusterNode>	PlatformFullTask.map(List<ClusterNode> subgrid, @Nullable Object arg)	This method is called to map or split grid task into multiple grid jobs.

Uses of ComputeJob in org.apache.ignite.internal.processors.resource

Methods in org.apache.ignite.internal.processors.resource with parameters of type ComputeJob

Modifier and Type	Method	Description
void	GridResourceProcessor.inject(GridDeployment dep, Class<?> taskCls, ComputeJob job, ComputeTaskSession ses, GridJobContextImpl jobCtx)	Injects held resources into given job.

Uses of ComputeJob in org.apache.ignite.internal.util.future

Methods in org.apache.ignite.internal.util.future that return types with arguments of type ComputeJob

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	IgniteRemoteMapTask.map(List<ClusterNode> subgrid, T arg)	This method is called to map or split grid task into multiple grid jobs.

Uses of ComputeJob in org.apache.ignite.internal.visor

Classes in org.apache.ignite.internal.visor that implement ComputeJob

Modifier and Type	Class	Description
class	VisorJob<A,R>	Base class for Visor jobs.

Methods in org.apache.ignite.internal.visor that return types with arguments of type ComputeJob

Modifier and Type	Method	Description
@NotNull Map<? extends ComputeJob,ClusterNode>	VisorMultiNodeTask.map(List<ClusterNode> subgrid, VisorTaskArgument<A> arg)	This method is called to map or split grid task into multiple grid jobs.
protected Map<? extends ComputeJob,ClusterNode>	VisorMultiNodeTask.map0(List<ClusterNode> subgrid, VisorTaskArgument<A> arg)	Actual map logic.

Uses of ComputeJob in org.apache.ignite.spi.collision

Methods in org.apache.ignite.spi.collision that return ComputeJob

Modifier and Type	Method	Description
ComputeJob	CollisionJobContext.getJob()	Job for this context.

Uses of ComputeJob in org.apache.ignite.spi.loadbalancing

Methods in org.apache.ignite.spi.loadbalancing with parameters of type ComputeJob

Modifier and Type	Method	Description
ClusterNode	LoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Uses of ComputeJob in org.apache.ignite.spi.loadbalancing.adaptive

Methods in org.apache.ignite.spi.loadbalancing.adaptive with parameters of type ComputeJob

Modifier and Type	Method	Description
ClusterNode	AdaptiveLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Uses of ComputeJob in org.apache.ignite.spi.loadbalancing.roundrobin

Methods in org.apache.ignite.spi.loadbalancing.roundrobin with parameters of type ComputeJob

Modifier and Type	Method	Description
ClusterNode	RoundRobinLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.

Uses of ComputeJob in org.apache.ignite.spi.loadbalancing.weightedrandom

Methods in org.apache.ignite.spi.loadbalancing.weightedrandom with parameters of type ComputeJob

Modifier and Type	Method	Description
ClusterNode	WeightedRandomLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)	Gets balanced node for specified job within given task session.