@InterfaceAudience.Private public class MetricsStochasticBalancer extends MetricsBalancer
Modifier and Type | Field and Description |
---|---|
private MetricsStochasticBalancerSource |
stochasticSource
Use the stochastic source instead of the default source.
|
Constructor and Description |
---|
MetricsStochasticBalancer() |
Modifier and Type | Method and Description |
---|---|
void |
balanceCluster(long time) |
void |
balancerStatus(boolean status)
Updates the balancer status tag reported to JMX
|
void |
incrMiscInvocations() |
protected void |
initSource()
This function overrides the initSource in the MetricsBalancer, use
MetricsStochasticBalancerSource instead of the MetricsBalancerSource.
|
void |
updateMetricsSize(int size)
Updates the number of metrics reported to JMX
|
void |
updateStochasticCost(String tableName,
String costFunctionName,
String costFunctionDesc,
Double value)
Reports stochastic load balancer costs to JMX
|
private MetricsStochasticBalancerSource stochasticSource
public MetricsStochasticBalancer()
protected void initSource()
initSource
in class MetricsBalancer
public void balanceCluster(long time)
balanceCluster
in class MetricsBalancer
public void incrMiscInvocations()
incrMiscInvocations
in class MetricsBalancer
public void balancerStatus(boolean status)
balancerStatus
in class MetricsBalancer
public void updateMetricsSize(int size)
public void updateStochasticCost(String tableName, String costFunctionName, String costFunctionDesc, Double value)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.