@InterfaceStability.Evolving @InterfaceAudience.Private public class MetricsRegionServer extends Object
This class is for maintaining the various regionserver statistics and publishing them through the metrics interfaces.
This class has a number of metrics variables that are publicly accessible; these variables (objects) have methods to update their values.Modifier and Type | Field and Description |
---|---|
static boolean |
RS_ENABLE_TABLE_METRICS_DEFAULT |
static String |
RS_ENABLE_TABLE_METRICS_KEY |
Constructor and Description |
---|
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
MetricsRegionServerSource |
getMetricsSource() |
MetricsRegionServerWrapper |
getRegionServerWrapper() |
void |
incrSplitRequest() |
void |
incrSplitSuccess() |
void |
updateAppend(TableName tn,
long t) |
void |
updateBulkLoad(long millis) |
void |
updateCheckAndDelete(long t) |
void |
updateCheckAndPut(long t) |
void |
updateCompaction(boolean isMajor,
long t,
int inputFileCount,
int outputFileCount,
long inputBytes,
long outputBytes) |
void |
updateDelete(TableName tn,
long t) |
void |
updateDeleteBatch(TableName tn,
long t) |
void |
updateFlush(long t,
long memstoreSize,
long fileSize) |
void |
updateGet(TableName tn,
long t) |
void |
updateIncrement(TableName tn,
long t) |
void |
updatePut(TableName tn,
long t) |
void |
updatePutBatch(TableName tn,
long t) |
void |
updateReplay(long t) |
void |
updateScanSize(TableName tn,
long scanSize) |
void |
updateScanTime(TableName tn,
long t) |
void |
updateSplitTime(long t) |
public static final String RS_ENABLE_TABLE_METRICS_KEY
public static final boolean RS_ENABLE_TABLE_METRICS_DEFAULT
public MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper, org.apache.hadoop.conf.Configuration conf)
public MetricsRegionServerSource getMetricsSource()
public MetricsRegionServerWrapper getRegionServerWrapper()
public void updatePutBatch(TableName tn, long t)
public void updatePut(TableName tn, long t)
public void updateDelete(TableName tn, long t)
public void updateDeleteBatch(TableName tn, long t)
public void updateCheckAndDelete(long t)
public void updateCheckAndPut(long t)
public void updateGet(TableName tn, long t)
public void updateIncrement(TableName tn, long t)
public void updateAppend(TableName tn, long t)
public void updateReplay(long t)
public void updateScanSize(TableName tn, long scanSize)
public void updateScanTime(TableName tn, long t)
public void updateSplitTime(long t)
public void incrSplitRequest()
public void incrSplitSuccess()
public void updateFlush(long t, long memstoreSize, long fileSize)
public void updateCompaction(boolean isMajor, long t, int inputFileCount, int outputFileCount, long inputBytes, long outputBytes)
public void updateBulkLoad(long millis)
Copyright © 2007–2019 Cloudera. All rights reserved.