Uses of Class
org.apache.ignite.spi.collision.jobstealing.JobStealingCollisionSpi
-
Packages that use JobStealingCollisionSpi Package Description org.apache.ignite.spi.collision.jobstealing Contains job stealing collision SPI implementation. -
-
Uses of JobStealingCollisionSpi in org.apache.ignite.spi.collision.jobstealing
Methods in org.apache.ignite.spi.collision.jobstealing that return JobStealingCollisionSpi Modifier and Type Method 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 (seeClusterNode.attribute(String)
andIgniteConfiguration.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.
-