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.
|
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 |
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.16.0 Release Date : December 15 2023