Package org.apache.hadoop.hbase.master

Class MetricsAssignmentManager

java.lang.Object

org.apache.hadoop.hbase.master.MetricsAssignmentManager

@Private
public class MetricsAssignmentManager
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final MetricsAssignmentManagerSource	assignmentManagerSource
private final ProcedureMetrics	assignProcMetrics
private final ProcedureMetrics	closeProcMetrics
private final ProcedureMetrics	mergeProcMetrics
private final ProcedureMetrics	moveProcMetrics
private final ProcedureMetrics	openProcMetrics
private final ProcedureMetrics	reopenProcMetrics
private final ProcedureMetrics	splitProcMetrics
private final ProcedureMetrics	unassignProcMetrics

Constructor Summary

Constructors

Constructor	Description
MetricsAssignmentManager()

Method Summary

Modifier and Type	Method	Description
ProcedureMetrics	getAssignProcMetrics()	Returns Set of common metrics for assign procedure
ProcedureMetrics	getCloseProcMetrics()	Returns Set of common metrics for CloseRegionProcedure
ProcedureMetrics	getMergeProcMetrics()	Returns Set of common metrics for merge procedure
MetricsAssignmentManagerSource	getMetricsProcSource()
ProcedureMetrics	getMoveProcMetrics()	Returns Set of common metrics for move procedure
ProcedureMetrics	getOpenProcMetrics()	Returns Set of common metrics for OpenRegionProcedure
ProcedureMetrics	getReopenProcMetrics()	Returns Set of common metrics for reopen procedure
ProcedureMetrics	getSplitProcMetrics()	Returns Set of common metrics for split procedure
ProcedureMetrics	getUnassignProcMetrics()	Returns Set of common metrics for unassign procedure
void	incrementOperationCounter()
void	updateDeadServerOpenRegions(int deadRegions)
void	updateEmptyRegionInfoRegions(int emptyRegionInfoRegions)
void	updateHoles(int holes)
void	updateInconsistentRegions(int inconsistentRegions)
void	updateOrphanRegionsOnFs(int orphanRegionsOnFs)
void	updateOrphanRegionsOnRs(int orphanRegionsOnRs)
void	updateOverlaps(int overlaps)
void	updateRITCount(int ritCount)	set new value for number of regions in transition.
void	updateRITCountOverThreshold(int ritCountOverThreshold)	update RIT count that are in this state for more than the threshold as defined by the property rit.metrics.threshold.time.
void	updateRitDuration(long duration)	update the duration metrics of region is transition
void	updateRITOldestAge(long timestamp)	update the timestamp for oldest region in transition metrics.
void	updateUnknownServerOpenRegions(int unknownRegions)
void	updateUnknownServerRegions(int unknownServerRegions)

Methods inherited from class java.lang.Object

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

Field Details

assignmentManagerSource

private final MetricsAssignmentManagerSource assignmentManagerSource

assignProcMetrics

private final ProcedureMetrics assignProcMetrics

unassignProcMetrics

private final ProcedureMetrics unassignProcMetrics

moveProcMetrics

private final ProcedureMetrics moveProcMetrics

reopenProcMetrics

private final ProcedureMetrics reopenProcMetrics

openProcMetrics

private final ProcedureMetrics openProcMetrics

closeProcMetrics

private final ProcedureMetrics closeProcMetrics

splitProcMetrics

private final ProcedureMetrics splitProcMetrics

mergeProcMetrics

private final ProcedureMetrics mergeProcMetrics

Constructor Details

MetricsAssignmentManager

public MetricsAssignmentManager()

Method Details

getMetricsProcSource

public MetricsAssignmentManagerSource getMetricsProcSource()

updateRITCount

public void updateRITCount(int ritCount)

set new value for number of regions in transition.

updateRITCountOverThreshold

public void updateRITCountOverThreshold(int ritCountOverThreshold)

update RIT count that are in this state for more than the threshold as defined by the property rit.metrics.threshold.time.

updateRITOldestAge

public void updateRITOldestAge(long timestamp)

update the timestamp for oldest region in transition metrics.

updateRitDuration

public void updateRitDuration(long duration)

update the duration metrics of region is transition

incrementOperationCounter

public void incrementOperationCounter()

updateDeadServerOpenRegions

public void updateDeadServerOpenRegions(int deadRegions)

updateUnknownServerOpenRegions

public void updateUnknownServerOpenRegions(int unknownRegions)

updateOrphanRegionsOnRs

public void updateOrphanRegionsOnRs(int orphanRegionsOnRs)

updateOrphanRegionsOnFs

public void updateOrphanRegionsOnFs(int orphanRegionsOnFs)

updateInconsistentRegions

public void updateInconsistentRegions(int inconsistentRegions)

updateHoles

public void updateHoles(int holes)

updateOverlaps

public void updateOverlaps(int overlaps)

updateUnknownServerRegions

public void updateUnknownServerRegions(int unknownServerRegions)

updateEmptyRegionInfoRegions

public void updateEmptyRegionInfoRegions(int emptyRegionInfoRegions)

getAssignProcMetrics

public ProcedureMetrics getAssignProcMetrics()

Returns Set of common metrics for assign procedure

getUnassignProcMetrics

public ProcedureMetrics getUnassignProcMetrics()

Returns Set of common metrics for unassign procedure

getMoveProcMetrics

public ProcedureMetrics getMoveProcMetrics()

Returns Set of common metrics for move procedure

getReopenProcMetrics

public ProcedureMetrics getReopenProcMetrics()

Returns Set of common metrics for reopen procedure

getOpenProcMetrics

public ProcedureMetrics getOpenProcMetrics()

Returns Set of common metrics for OpenRegionProcedure

getCloseProcMetrics

public ProcedureMetrics getCloseProcMetrics()

Returns Set of common metrics for CloseRegionProcedure

getSplitProcMetrics

public ProcedureMetrics getSplitProcMetrics()

Returns Set of common metrics for split procedure

getMergeProcMetrics

public ProcedureMetrics getMergeProcMetrics()

Returns Set of common metrics for merge procedure