@MXBeanDescription(value="MBean for job stealing based collision SPI.") public interface JobStealingCollisionSpiMBean extends IgniteSpiManagementMBean
| Modifier and Type | Method and Description |
|---|---|
int |
getActiveJobsThreshold()
Gets number of jobs that can be executed in parallel.
|
int |
getCurrentActiveJobsNumber()
Gets current number of jobs that are being executed.
|
int |
getCurrentHeldJobsNumber()
Gets number of currently
'held' jobs. |
int |
getCurrentJobsToStealNumber()
Gets current number of jobs to be stolen.
|
int |
getCurrentRunningJobsNumber() |
int |
getCurrentWaitJobsNumber()
Gets current number of jobs that wait for the execution.
|
int |
getMaximumStealingAttempts()
Gets maximum number of attempts to steal job by another node.
|
long |
getMessageExpireTime()
Message expire time configuration parameter.
|
Map<String,? extends Serializable> |
getStealingAttributes()
Configuration parameter to enable stealing to/from only nodes that
have these attributes set (see
ClusterNode.attribute(String) and
IgniteConfiguration.getUserAttributes() methods). |
int |
getTotalStolenJobsNumber()
Gets total number of stolen jobs.
|
int |
getWaitJobsThreshold()
Gets job count threshold at which this node will
start stealing jobs from other nodes.
|
boolean |
isStealingEnabled()
Gets flag indicating whether this node should attempt to steal jobs
from other nodes.
|
void |
setActiveJobsThreshold(int activeJobsTreshold)
Sets number of jobs that can be executed in parallel.
|
void |
setMaximumStealingAttempts(int maximumStealingAttempts)
Gets maximum number of attempts to steal job by another node.
|
void |
setMessageExpireTime(long msgExpireTime)
Message expire time configuration parameter.
|
void |
setStealingEnabled(boolean stealingEnabled)
Gets flag indicating whether this node should attempt to steal jobs
from other nodes.
|
void |
setWaitJobsThreshold(int waitJobsThreshold)
Sets job count threshold at which this node will
start stealing jobs from other nodes.
|
getIgniteHome, getLocalNodeId, getName, getStartTimestamp, getStartTimestampFormatted, getUpTime, getUpTimeFormatted@MXBeanDescription(value="Number of jobs to be stolen.") int getCurrentJobsToStealNumber()
@MXBeanDescription(value="Number of jobs that wait for execution.") int getCurrentWaitJobsNumber()
@MXBeanDescription(value="Number of active jobs.") int getCurrentActiveJobsNumber()
@MXBeanDescription(value="Number of running jobs.") int getCurrentRunningJobsNumber()
@MXBeanDescription(value="Number of held jobs.") int getCurrentHeldJobsNumber()
'held' jobs.'held' jobs.@MXBeanDescription(value="Number of stolen jobs.") int getTotalStolenJobsNumber()
@MXBeanDescription(value="Number of jobs that can be executed in parallel.") int getActiveJobsThreshold()
@MXBeanDescription(value="Number of jobs that can be executed in parallel.") void setActiveJobsThreshold(int activeJobsTreshold)
activeJobsTreshold - Number of jobs that can be executed in parallel.@MXBeanDescription(value="Job count threshold.") int getWaitJobsThreshold()
@MXBeanDescription(value="Job count threshold.") void setWaitJobsThreshold(int waitJobsThreshold)
waitJobsThreshold - Job count threshold.@MXBeanDescription(value="Message expire time.") long getMessageExpireTime()
@MXBeanDescription(value="Message expire time.") void setMessageExpireTime(long msgExpireTime)
msgExpireTime - Message expire time.@MXBeanDescription(value="Flag indicating whether this node should attempt to steal jobs from other nodes.") boolean isStealingEnabled()
false, then this node will steal allow
jobs to be stolen from it, but won't attempt to steal any jobs from
other nodes.
Default value is true.
@MXBeanDescription(value="Flag indicating whether this node should attempt to steal jobs from other nodes.") void setStealingEnabled(boolean stealingEnabled)
false, then this node will steal allow
jobs to be stolen from it, but won't attempt to steal any jobs from
other nodes.
Default value is true.
stealingEnabled - Flag indicating whether this node should attempt to steal jobs
from other nodes.@MXBeanDescription(value="Maximum number of attempts to steal job by another node.") int getMaximumStealingAttempts()
JobStealingCollisionSpi.DFLT_MAX_STEALING_ATTEMPTS
value will be used.@MXBeanDescription(value="Maximum number of attempts to steal job by another node.") void setMaximumStealingAttempts(int maximumStealingAttempts)
JobStealingCollisionSpi.DFLT_MAX_STEALING_ATTEMPTS
value will be used.maximumStealingAttempts - Maximum number of attempts to steal job by another node.@MXBeanDescription(value="Node attributes to enable job stealing for.") Map<String,? extends Serializable> getStealingAttributes()
ClusterNode.attribute(String) and
IgniteConfiguration.getUserAttributes() methods).
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016