@InterfaceStability.Evolving @InterfaceAudience.Private public class MetricsRegionServer extends java.lang.Object
Constructor and Description |
---|
MetricsRegionServer(Configuration conf,
MetricsRegionServerWrapper regionServerWrapper,
MetricsTable metricsTable) |
Modifier and Type | Method and Description |
---|---|
MetricsRegionServerSource |
getMetricsSource() |
MetricsUserAggregate |
getMetricsUserAggregate() |
MetricsRegionServerWrapper |
getRegionServerWrapper() |
void |
incrSplitRequest() |
void |
incrSplitSuccess() |
void |
updateAppend(long t) |
void |
updateCompaction(java.lang.String table,
boolean isMajor,
long t,
int inputFileCount,
int outputFileCount,
long inputBytes,
long outputBytes) |
void |
updateDelete(long t) |
void |
updateFlush(java.lang.String table,
long t,
long memstoreSize,
long fileSize) |
void |
updateGet(long t) |
void |
updateIncrement(long t) |
void |
updatePut(long t) |
void |
updateReplay(long t) |
void |
updateScanSize(long scanSize) |
void |
updateScanTime(long t) |
void |
updateSplitTime(long t) |
public MetricsRegionServer(Configuration conf, MetricsRegionServerWrapper regionServerWrapper, MetricsTable metricsTable)
public MetricsRegionServerSource getMetricsSource()
public MetricsUserAggregate getMetricsUserAggregate()
public MetricsRegionServerWrapper getRegionServerWrapper()
public void updatePut(long t)
public void updateDelete(long t)
public void updateGet(long t)
public void updateIncrement(long t)
public void updateAppend(long t)
public void updateReplay(long t)
public void updateScanSize(long scanSize)
public void updateScanTime(long t)
public void updateSplitTime(long t)
public void incrSplitRequest()
public void incrSplitSuccess()
public void updateFlush(java.lang.String table, long t, long memstoreSize, long fileSize)
public void updateCompaction(java.lang.String table, boolean isMajor, long t, int inputFileCount, int outputFileCount, long inputBytes, long outputBytes)