public class AdaptiveJobCountLoadProbe extends Object implements AdaptiveLoadProbe
setUseAverage(boolean)
parameter, this implementation will
either use average job count values or current (default is to use averages).
The load of a node is simply calculated by adding active and waiting job counts.
Below is an example of how CPU load probe would be configured in Ignite Spring configuration file:
<property name="loadBalancingSpi"> <bean class="org.apache.ignite.spi.loadBalancing.adaptive.GridAdaptiveLoadBalancingSpi"> <property name="loadProbe"> <bean class="org.apache.ignite.spi.loadBalancing.adaptive.GridAdaptiveJobCountLoadProbe"> <property name="useAverage" value="true"/> </bean> </property> </bean> </property>
Constructor and Description |
---|
AdaptiveJobCountLoadProbe()
Initializes active job probe.
|
AdaptiveJobCountLoadProbe(boolean useAvg)
Creates new active job prove specifying whether to use average
job counts vs. current.
|
Modifier and Type | Method and Description |
---|---|
double |
getLoad(ClusterNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
boolean |
isUseAverage()
Gets flag indicating whether to use average job counts vs. current.
|
void |
setUseAverage(boolean useAvg)
Sets flag indicating whether to use average job counts vs. current.
|
String |
toString() |
public AdaptiveJobCountLoadProbe()
public AdaptiveJobCountLoadProbe(boolean useAvg)
useAvg
- Flag indicating whether to use average job counts vs. current.public boolean isUseAverage()
public void setUseAverage(boolean useAvg)
useAvg
- Flag indicating whether to use average job counts vs. current.public double getLoad(ClusterNode node, int jobsSentSinceLastUpdate)
ClusterNode.metrics()
method. For example, load can be calculated
based on job execution time or number of active jobs, or CPU/Heap utilization.
Note that if this method returns a value of 0
,
then implementation will assume that load value is simply not available and
will try to calculate an average of load values for other nodes. If such
average cannot be obtained (all node load values are 0
), then a value
of 1
will be used.
getLoad
in interface AdaptiveLoadProbe
node
- Grid node to calculate load for.jobsSentSinceLastUpdate
- Number of jobs sent to this node since
last metrics update. This parameter may be useful when
implementation takes into account the current job count on a node.
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024