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.compute.gridify.aop	Contains common classes for different AOP providers.
org.apache.ignite.igfs.mapreduce	Contains APIs for In-Memory MapReduce over IGFS.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.managers.collision	TODO.
org.apache.ignite.internal.managers.loadbalancer	TODO.
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.query.jdbc
org.apache.ignite.internal.processors.closure	TODO.
org.apache.ignite.internal.processors.igfs	Contains high performance file system processor.
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.gridify	Utility classes for gridify annotations.
org.apache.ignite.internal.visor
org.apache.ignite.internal.visor.cache
org.apache.ignite.internal.visor.compute
org.apache.ignite.internal.visor.misc
org.apache.ignite.internal.visor.node
org.apache.ignite.internal.visor.query
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 and 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 and 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 and Description
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.
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.
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 and Description
ClusterNode	ComputeLoadBalancer.getBalancedNode(ComputeJob job, 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 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.

Uses of ComputeJob in org.apache.ignite.compute.gridify.aop

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

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

Uses of ComputeJob in org.apache.ignite.igfs.mapreduce

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

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

Uses of ComputeJob in org.apache.ignite.internal

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

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.

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

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)
GridJobResultImpl(ComputeJob job, IgniteUuid jobId, ClusterNode node, GridJobSiblingImpl sib)

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 and 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 and 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 and Description
protected static class	GridCacheAdapter.TopologyVersionAwareJob Delayed callable class.

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

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

Modifier and Type	Method and Description
Map<? extends ComputeJob,ClusterNode>	GridCacheQueryJdbcTask.map(List<ClusterNode> subgrid, byte[] arg) This method is called to map or split grid task into multiple grid jobs.
Map<? extends ComputeJob,ClusterNode>	GridCacheQueryJdbcMetadataTask.map(List<ClusterNode> subgrid, String cacheName) This method is called to map or split grid task into multiple grid jobs.
protected Collection<? extends ComputeJob>	GridCacheQueryJdbcValidationTask.split(int gridSize, String cacheName) This is a simplified version of ComputeTask.map(List, Object) method.

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 and Description
static class	GridClosureProcessor.C1MLAV2<T,R>
static class	GridClosureProcessor.C1V2<T,R>
static class	GridClosureProcessor.C2MLAV2<R>
static class	GridClosureProcessor.C2V2<R>
static class	GridClosureProcessor.C4MLAV2
static class	GridClosureProcessor.C4V2

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

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

Modifier and Type	Class and Description
class	IgfsJobImpl IGFS job implementation.

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

Modifier and Type	Method and Description
abstract ComputeJob	IgfsProcessorAdapter.createJob(IgfsJob job, String igfsName, IgfsPath path, long start, long length, IgfsRecordResolver recRslv) Create compute job for the given IGFS job.
ComputeJob	IgfsProcessor.createJob(IgfsJob job, String igfsName, IgfsPath path, long start, long len, IgfsRecordResolver recRslv) Create compute job for the given IGFS job.
ComputeJob	IgfsNoopProcessor.createJob(IgfsJob job, String igfsName, IgfsPath path, long start, long length, IgfsRecordResolver recRslv) Create compute job for the given IGFS job.

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 and Description
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 and Description
interface	PlatformJob Platform closure job interface.

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

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.

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

Modifier and Type	Method and Description
Map<? extends ComputeJob,ClusterNode>	PlatformBroadcastingSingleClosureTask.map(List<ClusterNode> subgrid, Object arg) This method is called to map or split grid task into multiple grid jobs.
Map<? extends ComputeJob,ClusterNode>	PlatformBroadcastingMultiClosureTask.map(List<ClusterNode> subgrid, Object arg) This method is called to map or split grid task into multiple grid jobs.
Map<? extends ComputeJob,ClusterNode>	PlatformBalancingMultiClosureTask.map(List<ClusterNode> subgrid, Object arg) This method is called to map or split grid task into multiple grid jobs.
Map<? extends ComputeJob,ClusterNode>	PlatformBalancingSingleClosureAffinityTask.map(List<ClusterNode> subgrid, Object arg) This method is called to map or split grid task into multiple grid jobs.
Map<? extends ComputeJob,ClusterNode>	PlatformFullTask.map(List<ClusterNode> subgrid, Object arg) This method is called to map or split grid task into multiple grid jobs.
Map<? extends ComputeJob,ClusterNode>	PlatformBalancingSingleClosureTask.map(List<ClusterNode> subgrid, 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 and 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.gridify

Classes in org.apache.ignite.internal.util.gridify that implement ComputeJob

Modifier and Type	Class and Description
class	GridifyJobAdapter Convenience adapter for custom gridify jobs.

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

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

Modifier and Type	Class and 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 and Description
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.internal.visor.cache

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

Modifier and Type	Class and Description
class	VisorCacheConfigurationCollectorJob Job that collect cache metrics from node.

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

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

Modifier and Type	Method and Description
Map<? extends ComputeJob,ClusterNode>	VisorGatewayTask.map(List<ClusterNode> subgrid, Object[] args) This method is called to map or split grid task into multiple grid jobs.

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

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

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

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

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

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.

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

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

Modifier and Type	Class and Description
class	VisorQueryJob Job for execute SCAN or SQL query and get first page of results.

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

Modifier and Type	Method and Description
protected Map<? extends ComputeJob,ClusterNode>	VisorQueryCleanupTask.map0(List<ClusterNode> subgrid, VisorTaskArgument<Map<UUID,Collection<String>>> 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 and 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 and 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 and 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 and 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 and Description
ClusterNode	WeightedRandomLoadBalancingSpi.getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job) Gets balanced node for specified job within given task session.