@InterfaceAudience.Private public class MetricsAssignmentManagerSourceImpl extends BaseSourceImpl implements MetricsAssignmentManagerSource
Modifier and Type | Field and Description |
---|---|
private OperationMetrics |
assignMetrics |
private OperationMetrics |
closeMetrics |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
deadServerOpenRegions |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
emptyRegionInfoRegionsGauge |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
holesGauge |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
inconsistentRegionsGauge |
private OperationMetrics |
mergeMetrics |
private OperationMetrics |
moveMetrics |
private OperationMetrics |
openMetrics |
private MutableFastCounter |
operationCounter |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
orphanRegionsOnFsGauge |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
orphanRegionsOnRsGauge |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
overlapsGauge |
private OperationMetrics |
reopenMetrics |
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 |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
unknownServerOpenRegions |
private org.apache.hadoop.metrics2.lib.MutableGaugeLong |
unknownServerRegionsGauge |
metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registry
ASSIGN_METRIC_PREFIX, CLOSE_METRIC_PREFIX, DEAD_SERVER_OPEN_REGIONS, EMPTY_REGION_INFO_REGIONS, EMPTY_REGION_INFO_REGIONS_DESC, HOLES, HOLES_DESC, INCONSISTENT_REGIONS, INCONSISTENT_REGIONS_DESC, MERGE_METRIC_PREFIX, METRICS_CONTEXT, METRICS_DESCRIPTION, METRICS_JMX_CONTEXT, METRICS_NAME, MOVE_METRIC_PREFIX, OPEN_METRIC_PREFIX, OPERATION_COUNT_NAME, ORPHAN_REGIONS_ON_FS, ORPHAN_REGIONS_ON_FS_DESC, ORPHAN_REGIONS_ON_RS, ORPHAN_REGIONS_ON_RS_DESC, OVERLAPS, OVERLAPS_DESC, REOPEN_METRIC_PREFIX, 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_PREFIX, UNKNOWN_SERVER_OPEN_REGIONS, UNKNOWN_SERVER_REGIONS, UNKNOWN_SERVER_REGIONS_DESC
HBASE_METRICS_SYSTEM_NAME
Constructor and Description |
---|
MetricsAssignmentManagerSourceImpl() |
MetricsAssignmentManagerSourceImpl(String metricsName,
String metricsDescription,
String metricsContext,
String metricsJmxContext) |
Modifier and Type | Method and Description |
---|---|
OperationMetrics |
getAssignMetrics()
Returns
OperationMetrics containing common metrics for assign region operation |
OperationMetrics |
getCloseMetrics()
Returns
OperationMetrics containing common metrics for close region request |
OperationMetrics |
getMergeMetrics()
Returns
OperationMetrics containing common metrics for merge operation |
void |
getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector,
boolean all) |
OperationMetrics |
getMoveMetrics()
Returns
OperationMetrics containing common metrics for move region operation |
OperationMetrics |
getOpenMetrics()
Returns
OperationMetrics containing common metrics for open region request |
OperationMetrics |
getReopenMetrics()
Returns
OperationMetrics containing common metrics for reopen region operation |
OperationMetrics |
getSplitMetrics()
Returns
OperationMetrics containing common metrics for split operation |
OperationMetrics |
getUnassignMetrics()
Returns
OperationMetrics containing common metrics for unassign region operation |
void |
incrementOperationCounter()
TODO: Remove.
|
void |
init()
Clear out the metrics and re-prepare the source.
|
void |
setEmptyRegionInfoRegions(int emptyRegionInfoRegions)
Set the number of regions with empty region info.
|
void |
setHoles(int holes)
Set the number of holes.
|
void |
setInconsistentRegions(int inconsistentRegions)
Set the number of inconsistent regions.
|
void |
setOrphanRegionsOnFs(int orphanRegionsOnFs)
Set the number of orphan regions on FS.
|
void |
setOrphanRegionsOnRs(int orphanRegionsOnRs)
Set the number of orphan regions on RS.
|
void |
setOverlaps(int overlaps)
Set the number of overlaps.
|
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 |
setUnknownServerRegions(int unknownServerRegions)
Set the number of unknown server regions.
|
void |
updateDeadServerOpenRegions(int deadRegions) |
void |
updateRitDuration(long duration) |
void |
updateUnknownServerOpenRegions(int unknownRegions) |
decGauge, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, removeMetric, setGauge, updateHistogram
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, removeMetric, setGauge, updateHistogram
private 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 org.apache.hadoop.metrics2.lib.MutableGaugeLong deadServerOpenRegions
private org.apache.hadoop.metrics2.lib.MutableGaugeLong unknownServerOpenRegions
private org.apache.hadoop.metrics2.lib.MutableGaugeLong orphanRegionsOnRsGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong orphanRegionsOnFsGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong inconsistentRegionsGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong holesGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong overlapsGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong unknownServerRegionsGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong emptyRegionInfoRegionsGauge
private MutableFastCounter operationCounter
private OperationMetrics assignMetrics
private OperationMetrics unassignMetrics
private OperationMetrics moveMetrics
private OperationMetrics reopenMetrics
private OperationMetrics openMetrics
private OperationMetrics closeMetrics
private OperationMetrics splitMetrics
private OperationMetrics mergeMetrics
public MetricsAssignmentManagerSourceImpl()
public MetricsAssignmentManagerSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext)
public void init()
BaseSource
init
in interface BaseSource
init
in class BaseSourceImpl
public void setRIT(int ritCount)
MetricsAssignmentManagerSource
setRIT
in interface MetricsAssignmentManagerSource
ritCount
- count of the regions in transition.public void setRITCountOverThreshold(int ritCount)
MetricsAssignmentManagerSource
setRITCountOverThreshold
in interface MetricsAssignmentManagerSource
ritCount
- number of regions in transition for longer than threshold.public void setRITOldestAge(long ritCount)
MetricsAssignmentManagerSource
setRITOldestAge
in interface MetricsAssignmentManagerSource
ritCount
- age of the oldest RIT.public void incrementOperationCounter()
MetricsAssignmentManagerSource
incrementOperationCounter
in interface MetricsAssignmentManagerSource
public void updateRitDuration(long duration)
updateRitDuration
in interface MetricsAssignmentManagerSource
public void updateDeadServerOpenRegions(int deadRegions)
updateDeadServerOpenRegions
in interface MetricsAssignmentManagerSource
public void updateUnknownServerOpenRegions(int unknownRegions)
updateUnknownServerOpenRegions
in interface MetricsAssignmentManagerSource
public void setOrphanRegionsOnRs(int orphanRegionsOnRs)
MetricsAssignmentManagerSource
setOrphanRegionsOnRs
in interface MetricsAssignmentManagerSource
orphanRegionsOnRs
- count of the orphan regions on RS in HBCK chore report.public void setOrphanRegionsOnFs(int orphanRegionsOnFs)
MetricsAssignmentManagerSource
setOrphanRegionsOnFs
in interface MetricsAssignmentManagerSource
orphanRegionsOnFs
- count of the orphan regions on FS in HBCK chore report.public void setInconsistentRegions(int inconsistentRegions)
MetricsAssignmentManagerSource
setInconsistentRegions
in interface MetricsAssignmentManagerSource
inconsistentRegions
- count of the inconsistent regions in HBCK chore report.public void setHoles(int holes)
MetricsAssignmentManagerSource
setHoles
in interface MetricsAssignmentManagerSource
holes
- count of the holes in CatalogJanitor Consistency report.public void setOverlaps(int overlaps)
MetricsAssignmentManagerSource
setOverlaps
in interface MetricsAssignmentManagerSource
overlaps
- count of the overlaps in CatalogJanitor Consistency report.public void setUnknownServerRegions(int unknownServerRegions)
MetricsAssignmentManagerSource
setUnknownServerRegions
in interface MetricsAssignmentManagerSource
unknownServerRegions
- count of the unknown server regions in CatalogJanitor Consistency
report.public void setEmptyRegionInfoRegions(int emptyRegionInfoRegions)
MetricsAssignmentManagerSource
setEmptyRegionInfoRegions
in interface MetricsAssignmentManagerSource
emptyRegionInfoRegions
- count of the regions with empty region info in CatalogJanitor
Consistency report.public OperationMetrics getAssignMetrics()
MetricsAssignmentManagerSource
OperationMetrics
containing common metrics for assign region operationgetAssignMetrics
in interface MetricsAssignmentManagerSource
public OperationMetrics getUnassignMetrics()
MetricsAssignmentManagerSource
OperationMetrics
containing common metrics for unassign region operationgetUnassignMetrics
in interface MetricsAssignmentManagerSource
public OperationMetrics getSplitMetrics()
MetricsAssignmentManagerSource
OperationMetrics
containing common metrics for split operationgetSplitMetrics
in interface MetricsAssignmentManagerSource
public OperationMetrics getMergeMetrics()
MetricsAssignmentManagerSource
OperationMetrics
containing common metrics for merge operationgetMergeMetrics
in interface MetricsAssignmentManagerSource
public OperationMetrics getMoveMetrics()
MetricsAssignmentManagerSource
OperationMetrics
containing common metrics for move region operationgetMoveMetrics
in interface MetricsAssignmentManagerSource
public OperationMetrics getReopenMetrics()
MetricsAssignmentManagerSource
OperationMetrics
containing common metrics for reopen region operationgetReopenMetrics
in interface MetricsAssignmentManagerSource
public OperationMetrics getOpenMetrics()
MetricsAssignmentManagerSource
OperationMetrics
containing common metrics for open region requestgetOpenMetrics
in interface MetricsAssignmentManagerSource
public OperationMetrics getCloseMetrics()
MetricsAssignmentManagerSource
OperationMetrics
containing common metrics for close region requestgetCloseMetrics
in interface MetricsAssignmentManagerSource
public void getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector, boolean all)
getMetrics
in interface org.apache.hadoop.metrics2.MetricsSource
getMetrics
in class BaseSourceImpl
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.