@InterfaceAudience.Private public class MetricsAssignmentManager extends Object
Modifier and Type | Field and Description |
---|---|
private MetricsAssignmentManagerSource |
assignmentManagerSource |
private ProcedureMetrics |
assignProcMetrics |
private ProcedureMetrics |
mergeProcMetrics |
private ProcedureMetrics |
splitProcMetrics |
private ProcedureMetrics |
unassignProcMetrics |
Constructor and Description |
---|
MetricsAssignmentManager() |
Modifier and Type | Method and Description |
---|---|
ProcedureMetrics |
getAssignProcMetrics() |
ProcedureMetrics |
getMergeProcMetrics() |
MetricsAssignmentManagerSource |
getMetricsProcSource() |
ProcedureMetrics |
getSplitProcMetrics() |
ProcedureMetrics |
getUnassignProcMetrics() |
void |
incrementOperationCounter() |
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.
|
private final MetricsAssignmentManagerSource assignmentManagerSource
private final ProcedureMetrics assignProcMetrics
private final ProcedureMetrics unassignProcMetrics
private final ProcedureMetrics splitProcMetrics
private final ProcedureMetrics mergeProcMetrics
public MetricsAssignmentManager()
public MetricsAssignmentManagerSource getMetricsProcSource()
public void updateRITCount(int ritCount)
ritCount
- public void updateRITCountOverThreshold(int ritCountOverThreshold)
ritCountOverThreshold
- public void updateRITOldestAge(long timestamp)
timestamp
- public void updateRitDuration(long duration)
duration
- public void incrementOperationCounter()
public ProcedureMetrics getAssignProcMetrics()
public ProcedureMetrics getUnassignProcMetrics()
public ProcedureMetrics getSplitProcMetrics()
public ProcedureMetrics getMergeProcMetrics()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.