@InterfaceStability.Evolving @InterfaceAudience.Private public class MetricsRegionServer extends Object
Modifier and Type | Field and Description |
---|---|
private Timer |
bulkLoadTimer |
protected static int |
DEFAULT_SLOW_METRIC_TIME |
private MetricRegistry |
metricRegistry |
private MetricsTable |
metricsTable |
private MetricsRegionServerQuotaSource |
quotaSource |
private MetricsRegionServerWrapper |
regionServerWrapper |
static String |
RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY |
static boolean |
RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY_DEFAULT |
private Meter |
serverReadQueryMeter |
private MetricsRegionServerSource |
serverSource |
private Meter |
serverWriteQueryMeter |
static String |
SLOW_METRIC_TIME |
protected long |
slowMetricTime |
private MetricsUserAggregate |
userAggregate |
Constructor and Description |
---|
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper,
org.apache.hadoop.conf.Configuration conf,
MetricsTable metricsTable) |
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper,
MetricsRegionServerSource serverSource,
MetricsTable metricsTable,
MetricsUserAggregate userAggregate) |
Modifier and Type | Method and Description |
---|---|
MetricsRegionServerSource |
getMetricsSource() |
MetricsUserAggregate |
getMetricsUserAggregate() |
MetricsRegionServerWrapper |
getRegionServerWrapper() |
void |
incrementNumRegionSizeReportsSent(long numReportsSent) |
void |
incrementRegionSizeReportingChoreTime(long time) |
void |
incrScannerLeaseExpired() |
void |
incrSplitRequest() |
void |
incrSplitSuccess() |
void |
updateAppend(HRegion region,
long time,
long blockBytesScanned) |
void |
updateBulkLoad(long millis) |
void |
updateCheckAndDelete(HRegion region,
long t) |
void |
updateCheckAndMutate(HRegion region,
long time,
long blockBytesScanned) |
void |
updateCheckAndPut(HRegion region,
long t) |
void |
updateCompaction(String table,
boolean isMajor,
long t,
int inputFileCount,
int outputFileCount,
long inputBytes,
long outputBytes) |
void |
updateDelete(HRegion region,
long t) |
void |
updateDeleteBatch(HRegion region,
long t) |
void |
updateFlush(String table,
long t,
long memstoreSize,
long fileSize) |
void |
updateGet(HRegion region,
long time,
long blockBytesScanned) |
void |
updateIncrement(HRegion region,
long time,
long blockBytesScanned) |
void |
updatePut(HRegion region,
long t) |
void |
updatePutBatch(HRegion region,
long t) |
void |
updateReadQueryMeter(HRegion region,
long count) |
void |
updateReplay(long t) |
void |
updateScan(HRegion region,
long time,
long responseCellSize,
long blockBytesScanned) |
void |
updateSplitTime(long t) |
void |
updateWriteQueryMeter(HRegion region) |
void |
updateWriteQueryMeter(HRegion region,
long count) |
public static final String RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY
public static final boolean RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY_DEFAULT
public static final String SLOW_METRIC_TIME
private final MetricsRegionServerSource serverSource
private final MetricsRegionServerWrapper regionServerWrapper
private final MetricsTable metricsTable
private MetricsRegionServerQuotaSource quotaSource
private final MetricsUserAggregate userAggregate
private MetricRegistry metricRegistry
private Timer bulkLoadTimer
private Meter serverReadQueryMeter
private Meter serverWriteQueryMeter
protected long slowMetricTime
protected static final int DEFAULT_SLOW_METRIC_TIME
public MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper, org.apache.hadoop.conf.Configuration conf, MetricsTable metricsTable)
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper, MetricsRegionServerSource serverSource, MetricsTable metricsTable, MetricsUserAggregate userAggregate)
public MetricsRegionServerSource getMetricsSource()
public MetricsUserAggregate getMetricsUserAggregate()
public MetricsRegionServerWrapper getRegionServerWrapper()
public void updatePutBatch(HRegion region, long t)
public void updateDelete(HRegion region, long t)
public void updateDeleteBatch(HRegion region, long t)
public void updateCheckAndDelete(HRegion region, long t)
public void updateCheckAndPut(HRegion region, long t)
public void updateCheckAndMutate(HRegion region, long time, long blockBytesScanned)
public void updateIncrement(HRegion region, long time, long blockBytesScanned)
public void updateAppend(HRegion region, long time, long blockBytesScanned)
public void updateReplay(long t)
public void updateScan(HRegion region, long time, long responseCellSize, long blockBytesScanned)
public void updateSplitTime(long t)
public void incrSplitRequest()
public void incrSplitSuccess()
public void updateFlush(String table, long t, long memstoreSize, long fileSize)
public void updateCompaction(String table, boolean isMajor, long t, int inputFileCount, int outputFileCount, long inputBytes, long outputBytes)
public void updateBulkLoad(long millis)
public void incrementNumRegionSizeReportsSent(long numReportsSent)
public void incrementRegionSizeReportingChoreTime(long time)
public void updateReadQueryMeter(HRegion region, long count)
public void updateWriteQueryMeter(HRegion region, long count)
public void updateWriteQueryMeter(HRegion region)
public void incrScannerLeaseExpired()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.