@InterfaceAudience.Private public class MetricsAssignmentManager extends Object
Modifier and Type | Field and Description |
---|---|
private MetricsAssignmentManagerSource |
assignmentManagerSource |
private ProcedureMetrics |
assignProcMetrics |
private ProcedureMetrics |
closeProcMetrics |
private ProcedureMetrics |
mergeProcMetrics |
private ProcedureMetrics |
moveProcMetrics |
private ProcedureMetrics |
openProcMetrics |
private ProcedureMetrics |
reopenProcMetrics |
private ProcedureMetrics |
splitProcMetrics |
private ProcedureMetrics |
unassignProcMetrics |
Constructor and Description |
---|
MetricsAssignmentManager() |
Modifier and Type | Method and 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 n
|
void |
updateRITOldestAge(long timestamp)
update the timestamp for oldest region in transition metrics.
|
void |
updateUnknownServerOpenRegions(int unknownRegions) |
void |
updateUnknownServerRegions(int unknownServerRegions) |
private final MetricsAssignmentManagerSource assignmentManagerSource
private final ProcedureMetrics assignProcMetrics
private final ProcedureMetrics unassignProcMetrics
private final ProcedureMetrics moveProcMetrics
private final ProcedureMetrics reopenProcMetrics
private final ProcedureMetrics openProcMetrics
private final ProcedureMetrics closeProcMetrics
private final ProcedureMetrics splitProcMetrics
private final ProcedureMetrics mergeProcMetrics
public MetricsAssignmentManager()
public MetricsAssignmentManagerSource getMetricsProcSource()
public void updateRITCount(int ritCount)
public void updateRITCountOverThreshold(int ritCountOverThreshold)
public void updateRITOldestAge(long timestamp)
public void updateRitDuration(long duration)
public void incrementOperationCounter()
public void updateDeadServerOpenRegions(int deadRegions)
public void updateUnknownServerOpenRegions(int unknownRegions)
public void updateOrphanRegionsOnRs(int orphanRegionsOnRs)
public void updateOrphanRegionsOnFs(int orphanRegionsOnFs)
public void updateInconsistentRegions(int inconsistentRegions)
public void updateHoles(int holes)
public void updateOverlaps(int overlaps)
public void updateUnknownServerRegions(int unknownServerRegions)
public void updateEmptyRegionInfoRegions(int emptyRegionInfoRegions)
public ProcedureMetrics getAssignProcMetrics()
public ProcedureMetrics getUnassignProcMetrics()
public ProcedureMetrics getMoveProcMetrics()
public ProcedureMetrics getReopenProcMetrics()
public ProcedureMetrics getOpenProcMetrics()
public ProcedureMetrics getCloseProcMetrics()
public ProcedureMetrics getSplitProcMetrics()
public ProcedureMetrics getMergeProcMetrics()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.