@InterfaceAudience.Private public class MetricsAssignmentManagerSourceImpl extends BaseSourceImpl implements MetricsAssignmentManagerSource
| Modifier and Type | Field and Description |
|---|---|
private OperationMetrics |
assignMetrics |
private OperationMetrics |
mergeMetrics |
private MutableFastCounter |
operationCounter |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
ritCountOverThresholdGauge |
private MetricHistogram |
ritDurationHisto |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
ritGauge |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
ritOldestAgeGauge |
private OperationMetrics |
splitMetrics |
private OperationMetrics |
unassignMetrics |
metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registryASSIGN_METRIC_PREFIX, MERGE_METRIC_PREFIX, METRICS_CONTEXT, METRICS_DESCRIPTION, METRICS_JMX_CONTEXT, METRICS_NAME, OPERATION_COUNT_NAME, RIT_COUNT_DESC, RIT_COUNT_NAME, RIT_COUNT_OVER_THRESHOLD_DESC, RIT_COUNT_OVER_THRESHOLD_NAME, RIT_DURATION_DESC, RIT_DURATION_NAME, RIT_OLDEST_AGE_DESC, RIT_OLDEST_AGE_NAME, SPLIT_METRIC_PREFIX, UNASSIGN_METRIC_PREFIXHBASE_METRICS_SYSTEM_NAME| Constructor and Description |
|---|
MetricsAssignmentManagerSourceImpl() |
MetricsAssignmentManagerSourceImpl(String metricsName,
String metricsDescription,
String metricsContext,
String metricsJmxContext) |
| Modifier and Type | Method and Description |
|---|---|
OperationMetrics |
getAssignMetrics() |
OperationMetrics |
getMergeMetrics() |
OperationMetrics |
getSplitMetrics() |
OperationMetrics |
getUnassignMetrics() |
void |
incrementOperationCounter()
TODO: Remove.
|
void |
init()
Clear out the metrics and re-prepare the source.
|
void |
setRIT(int ritCount)
Set the number of regions in transition.
|
void |
setRITCountOverThreshold(int ritCount)
Set the count of the number of regions that have been in transition over the threshold time.
|
void |
setRITOldestAge(long ritCount)
Set the oldest region in transition.
|
void |
updateRitDuration(long duration) |
decGauge, getMetrics, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, removeMetric, setGauge, updateHistogramclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdecGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, removeMetric, setGauge, updateHistogramprivate org.apache.hadoop.metrics2.lib.MutableGaugeLong ritGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong ritCountOverThresholdGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong ritOldestAgeGauge
private MetricHistogram ritDurationHisto
private MutableFastCounter operationCounter
private OperationMetrics assignMetrics
private OperationMetrics unassignMetrics
private OperationMetrics splitMetrics
private OperationMetrics mergeMetrics
public MetricsAssignmentManagerSourceImpl()
public MetricsAssignmentManagerSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext)
public void init()
BaseSourceinit in interface BaseSourceinit in class BaseSourceImplpublic void setRIT(int ritCount)
MetricsAssignmentManagerSourcesetRIT in interface MetricsAssignmentManagerSourceritCount - count of the regions in transition.public void setRITCountOverThreshold(int ritCount)
MetricsAssignmentManagerSourcesetRITCountOverThreshold in interface MetricsAssignmentManagerSourceritCount - number of regions in transition for longer than threshold.public void setRITOldestAge(long ritCount)
MetricsAssignmentManagerSourcesetRITOldestAge in interface MetricsAssignmentManagerSourceritCount - age of the oldest RIT.public void incrementOperationCounter()
MetricsAssignmentManagerSourceincrementOperationCounter in interface MetricsAssignmentManagerSourcepublic void updateRitDuration(long duration)
updateRitDuration in interface MetricsAssignmentManagerSourcepublic OperationMetrics getAssignMetrics()
getAssignMetrics in interface MetricsAssignmentManagerSourceOperationMetrics containing common metrics for assign operationpublic OperationMetrics getUnassignMetrics()
getUnassignMetrics in interface MetricsAssignmentManagerSourceOperationMetrics containing common metrics for unassign operationpublic OperationMetrics getSplitMetrics()
getSplitMetrics in interface MetricsAssignmentManagerSourceOperationMetrics containing common metrics for split operationpublic OperationMetrics getMergeMetrics()
getMergeMetrics in interface MetricsAssignmentManagerSourceOperationMetrics containing common metrics for merge operationCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.