Package org.apache.hadoop.hbase.master

Class MetricsAssignmentManagerSourceImpl

java.lang.Object

org.apache.hadoop.hbase.metrics.BaseSourceImpl

org.apache.hadoop.hbase.master.MetricsAssignmentManagerSourceImpl

All Implemented Interfaces:

MetricsAssignmentManagerSource, BaseSource, org.apache.hadoop.metrics2.MetricsSource

@Private
public class MetricsAssignmentManagerSourceImpl
extends BaseSourceImpl
implements MetricsAssignmentManagerSource

Field Summary

Fields

Modifier and Type	Field	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

Fields inherited from class org.apache.hadoop.hbase.metrics.BaseSourceImpl

metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registry

Fields inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

HBASE_METRICS_SYSTEM_NAME

Fields inherited from interface org.apache.hadoop.hbase.master.MetricsAssignmentManagerSource

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

Constructor Summary

Constructors

Constructor	Description
MetricsAssignmentManagerSourceImpl()
MetricsAssignmentManagerSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class org.apache.hadoop.hbase.metrics.BaseSourceImpl

decGauge, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, removeMetric, setGauge, updateHistogram

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

decGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, removeMetric, setGauge, updateHistogram

Field Details

ritGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong ritGauge

ritCountOverThresholdGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong ritCountOverThresholdGauge

ritOldestAgeGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong ritOldestAgeGauge

ritDurationHisto

private MetricHistogram ritDurationHisto

deadServerOpenRegions

private org.apache.hadoop.metrics2.lib.MutableGaugeLong deadServerOpenRegions

unknownServerOpenRegions

private org.apache.hadoop.metrics2.lib.MutableGaugeLong unknownServerOpenRegions

orphanRegionsOnRsGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong orphanRegionsOnRsGauge

orphanRegionsOnFsGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong orphanRegionsOnFsGauge

inconsistentRegionsGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong inconsistentRegionsGauge

holesGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong holesGauge

overlapsGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong overlapsGauge

unknownServerRegionsGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong unknownServerRegionsGauge

emptyRegionInfoRegionsGauge

private org.apache.hadoop.metrics2.lib.MutableGaugeLong emptyRegionInfoRegionsGauge

operationCounter

private MutableFastCounter operationCounter

assignMetrics

private OperationMetrics assignMetrics

unassignMetrics

private OperationMetrics unassignMetrics

moveMetrics

private OperationMetrics moveMetrics

reopenMetrics

private OperationMetrics reopenMetrics

openMetrics

private OperationMetrics openMetrics

closeMetrics

private OperationMetrics closeMetrics

splitMetrics

private OperationMetrics splitMetrics

mergeMetrics

private OperationMetrics mergeMetrics

Constructor Details

MetricsAssignmentManagerSourceImpl

public MetricsAssignmentManagerSourceImpl()

MetricsAssignmentManagerSourceImpl

public MetricsAssignmentManagerSourceImpl(String metricsName,
 String metricsDescription,
 String metricsContext,
 String metricsJmxContext)

Method Details

init

public void init()

Description copied from interface: BaseSource

Clear out the metrics and re-prepare the source.

Specified by:

init in interface BaseSource

Overrides:

init in class BaseSourceImpl

setRIT

public void setRIT(int ritCount)

Description copied from interface: MetricsAssignmentManagerSource

Set the number of regions in transition.

Specified by:

setRIT in interface MetricsAssignmentManagerSource

Parameters:

ritCount - count of the regions in transition.

setRITCountOverThreshold

public void setRITCountOverThreshold(int ritCount)

Description copied from interface: MetricsAssignmentManagerSource

Set the count of the number of regions that have been in transition over the threshold time.

Specified by:

setRITCountOverThreshold in interface MetricsAssignmentManagerSource

Parameters:

ritCount - number of regions in transition for longer than threshold.

setRITOldestAge

public void setRITOldestAge(long ritCount)

Description copied from interface: MetricsAssignmentManagerSource

Set the oldest region in transition.

Specified by:

setRITOldestAge in interface MetricsAssignmentManagerSource

Parameters:

ritCount - age of the oldest RIT.

incrementOperationCounter

public void incrementOperationCounter()

Description copied from interface: MetricsAssignmentManagerSource

TODO: Remove. This may not be needed now as assign and unassign counts are tracked separately Increment the count of operations (assign/unassign).

Specified by:

incrementOperationCounter in interface MetricsAssignmentManagerSource

updateRitDuration

public void updateRitDuration(long duration)

Specified by:

updateRitDuration in interface MetricsAssignmentManagerSource

updateDeadServerOpenRegions

public void updateDeadServerOpenRegions(int deadRegions)

Specified by:

updateDeadServerOpenRegions in interface MetricsAssignmentManagerSource

updateUnknownServerOpenRegions

public void updateUnknownServerOpenRegions(int unknownRegions)

Specified by:

updateUnknownServerOpenRegions in interface MetricsAssignmentManagerSource

setOrphanRegionsOnRs

public void setOrphanRegionsOnRs(int orphanRegionsOnRs)

Description copied from interface: MetricsAssignmentManagerSource

Set the number of orphan regions on RS.

Specified by:

setOrphanRegionsOnRs in interface MetricsAssignmentManagerSource

Parameters:

orphanRegionsOnRs - count of the orphan regions on RS in HBCK chore report.

setOrphanRegionsOnFs

public void setOrphanRegionsOnFs(int orphanRegionsOnFs)

Description copied from interface: MetricsAssignmentManagerSource

Set the number of orphan regions on FS.

Specified by:

setOrphanRegionsOnFs in interface MetricsAssignmentManagerSource

Parameters:

orphanRegionsOnFs - count of the orphan regions on FS in HBCK chore report.

setInconsistentRegions

public void setInconsistentRegions(int inconsistentRegions)

Description copied from interface: MetricsAssignmentManagerSource

Set the number of inconsistent regions.

Specified by:

setInconsistentRegions in interface MetricsAssignmentManagerSource

Parameters:

inconsistentRegions - count of the inconsistent regions in HBCK chore report.

setHoles

public void setHoles(int holes)

Description copied from interface: MetricsAssignmentManagerSource

Set the number of holes.

Specified by:

setHoles in interface MetricsAssignmentManagerSource

Parameters:

holes - count of the holes in CatalogJanitor Consistency report.

setOverlaps

public void setOverlaps(int overlaps)

Description copied from interface: MetricsAssignmentManagerSource

Set the number of overlaps.

Specified by:

setOverlaps in interface MetricsAssignmentManagerSource

Parameters:

overlaps - count of the overlaps in CatalogJanitor Consistency report.

setUnknownServerRegions

public void setUnknownServerRegions(int unknownServerRegions)

Description copied from interface: MetricsAssignmentManagerSource

Set the number of unknown server regions.

Specified by:

setUnknownServerRegions in interface MetricsAssignmentManagerSource

Parameters:

unknownServerRegions - count of the unknown server regions in CatalogJanitor Consistency report.

setEmptyRegionInfoRegions

public void setEmptyRegionInfoRegions(int emptyRegionInfoRegions)

Description copied from interface: MetricsAssignmentManagerSource

Set the number of regions with empty region info.

Specified by:

setEmptyRegionInfoRegions in interface MetricsAssignmentManagerSource

Parameters:

emptyRegionInfoRegions - count of the regions with empty region info in CatalogJanitor Consistency report.

getAssignMetrics

public OperationMetrics getAssignMetrics()

Description copied from interface: MetricsAssignmentManagerSource

Returns OperationMetrics containing common metrics for assign region operation

Specified by:

getAssignMetrics in interface MetricsAssignmentManagerSource

getUnassignMetrics

public OperationMetrics getUnassignMetrics()

Description copied from interface: MetricsAssignmentManagerSource

Returns OperationMetrics containing common metrics for unassign region operation

Specified by:

getUnassignMetrics in interface MetricsAssignmentManagerSource

getSplitMetrics

public OperationMetrics getSplitMetrics()

Description copied from interface: MetricsAssignmentManagerSource

Returns OperationMetrics containing common metrics for split operation

Specified by:

getSplitMetrics in interface MetricsAssignmentManagerSource

getMergeMetrics

public OperationMetrics getMergeMetrics()

Description copied from interface: MetricsAssignmentManagerSource

Returns OperationMetrics containing common metrics for merge operation

Specified by:

getMergeMetrics in interface MetricsAssignmentManagerSource

getMoveMetrics

public OperationMetrics getMoveMetrics()

Description copied from interface: MetricsAssignmentManagerSource

Returns OperationMetrics containing common metrics for move region operation

Specified by:

getMoveMetrics in interface MetricsAssignmentManagerSource

getReopenMetrics

public OperationMetrics getReopenMetrics()

Description copied from interface: MetricsAssignmentManagerSource

Returns OperationMetrics containing common metrics for reopen region operation

Specified by:

getReopenMetrics in interface MetricsAssignmentManagerSource

getOpenMetrics

public OperationMetrics getOpenMetrics()

Description copied from interface: MetricsAssignmentManagerSource

Returns OperationMetrics containing common metrics for open region request

Specified by:

getOpenMetrics in interface MetricsAssignmentManagerSource

getCloseMetrics

public OperationMetrics getCloseMetrics()

Description copied from interface: MetricsAssignmentManagerSource

Returns OperationMetrics containing common metrics for close region request

Specified by:

getCloseMetrics in interface MetricsAssignmentManagerSource

getMetrics

public void getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector,
 boolean all)

Specified by:

getMetrics in interface org.apache.hadoop.metrics2.MetricsSource

Overrides:

getMetrics in class BaseSourceImpl