@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 |
---|---|
private Timer |
bulkLoadTimer |
private MetricRegistry |
metricRegistry |
private MetricsRegionServerQuotaSource |
quotaSource |
private MetricsRegionServerWrapper |
regionServerWrapper |
static boolean |
RS_ENABLE_TABLE_METRICS_DEFAULT |
static String |
RS_ENABLE_TABLE_METRICS_KEY |
private Meter |
serverReadQueryMeter |
private MetricsRegionServerSource |
serverSource |
private Meter |
serverWriteQueryMeter |
private RegionServerTableMetrics |
tableMetrics |
Constructor and Description |
---|
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper,
org.apache.hadoop.conf.Configuration conf) |
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper,
MetricsRegionServerSource serverSource,
RegionServerTableMetrics tableMetrics) |
Modifier and Type | Method and Description |
---|---|
(package private) static RegionServerTableMetrics |
createTableMetrics(org.apache.hadoop.conf.Configuration conf)
Creates an instance of
RegionServerTableMetrics only if the feature is enabled. |
MetricsRegionServerSource |
getMetricsSource() |
MetricsRegionServerWrapper |
getRegionServerWrapper() |
void |
incrementNumRegionSizeReportsSent(long numReportsSent) |
void |
incrementRegionSizeReportingChoreTime(long time) |
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 |
updateReadQueryMeter(TableName tn) |
void |
updateReadQueryMeter(TableName tn,
long count) |
void |
updateReplay(long t) |
void |
updateScanSize(TableName tn,
long scanSize) |
void |
updateScanTime(TableName tn,
long t) |
void |
updateSplitTime(long t) |
void |
updateWriteQueryMeter(TableName tn) |
void |
updateWriteQueryMeter(TableName tn,
long count) |
public static final String RS_ENABLE_TABLE_METRICS_KEY
public static final boolean RS_ENABLE_TABLE_METRICS_DEFAULT
private MetricsRegionServerSource serverSource
private MetricsRegionServerWrapper regionServerWrapper
private RegionServerTableMetrics tableMetrics
private MetricsRegionServerQuotaSource quotaSource
private MetricRegistry metricRegistry
private Timer bulkLoadTimer
private Meter serverReadQueryMeter
private Meter serverWriteQueryMeter
public MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper, org.apache.hadoop.conf.Configuration conf)
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper, MetricsRegionServerSource serverSource, RegionServerTableMetrics tableMetrics)
static RegionServerTableMetrics createTableMetrics(org.apache.hadoop.conf.Configuration conf)
RegionServerTableMetrics
only if the feature is enabled.public MetricsRegionServerSource getMetricsSource()
public MetricsRegionServerWrapper getRegionServerWrapper()
public void updatePutBatch(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 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)
public void updateReadQueryMeter(TableName tn, long count)
public void updateReadQueryMeter(TableName tn)
public void updateWriteQueryMeter(TableName tn, long count)
public void updateWriteQueryMeter(TableName tn)
public void incrementNumRegionSizeReportsSent(long numReportsSent)
public void incrementRegionSizeReportingChoreTime(long time)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.