Package | Description |
---|---|
org.apache.ignite.spi.collision.jobstealing |
Contains job stealing collision SPI implementation.
|
Modifier and Type | Method and Description |
---|---|
JobStealingCollisionSpi |
JobStealingCollisionSpi.setActiveJobsThreshold(int activeJobsThreshold)
Sets number of jobs that can be executed in parallel.
|
JobStealingCollisionSpi |
JobStealingCollisionSpi.setMaximumStealingAttempts(int maxStealingAttempts)
Gets maximum number of attempts to steal job by another node.
|
JobStealingCollisionSpi |
JobStealingCollisionSpi.setMessageExpireTime(long msgExpireTime)
Message expire time configuration parameter.
|
JobStealingCollisionSpi |
JobStealingCollisionSpi.setName(String name)
Sets SPI name.
|
JobStealingCollisionSpi |
JobStealingCollisionSpi.setStealingAttributes(Map<String,? extends Serializable> stealAttrs)
Configuration parameter to enable stealing to/from only nodes that
have these attributes set (see
ClusterNode.attribute(String) and
IgniteConfiguration.getUserAttributes() methods). |
JobStealingCollisionSpi |
JobStealingCollisionSpi.setStealingEnabled(boolean isStealingEnabled)
Gets flag indicating whether this node should attempt to steal jobs
from other nodes.
|
JobStealingCollisionSpi |
JobStealingCollisionSpi.setWaitJobsThreshold(int waitJobsThreshold)
Sets job count threshold at which this node will
start stealing jobs from other nodes.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.16.0 Release Date : December 15 2023