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.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 forComputeJob
implementations.class
ComputeJobContinuationAdapter
Convenience adapter forComputeJob
implementations.Methods in org.apache.ignite.compute with type parameters of type ComputeJob Modifier and Type Method Description <T extends ComputeJob>
TComputeJobResult. getJob()
Gets local instance of remote job returned byComputeTask.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 ofComputeTask.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.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.
-