Package org.apache.hadoop.hbase.regionserver

Class MetricsRegionServer

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsRegionServer

@Evolving
@Private
public class MetricsRegionServer
extends Object

Maintains regionserver statistics and publishes 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. Batch your updates rather than call on each instance else all threads will do nothing but contend trying to maintain metric counters!

Field Summary

Fields

Modifier and Type	Field	Description
private Timer	bulkLoadTimer
protected static final int	DEFAULT_SLOW_METRIC_TIME
private MetricRegistry	metricRegistry
private final MetricsTable	metricsTable
private MetricsRegionServerQuotaSource	quotaSource
private final MetricsRegionServerWrapper	regionServerWrapper
static final String	RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY
static final boolean	RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY_DEFAULT
private Meter	serverReadQueryMeter
private final MetricsRegionServerSource	serverSource
private Meter	serverWriteQueryMeter
static final String	SLOW_METRIC_TIME
protected long	slowMetricTime
private final MetricsUserAggregate	userAggregate

Constructor Summary

Constructors

Constructor	Description
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper, org.apache.hadoop.conf.Configuration conf, MetricsTable metricsTable)
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper, MetricsRegionServerSource serverSource, MetricsTable metricsTable, MetricsUserAggregate userAggregate)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY

public static final String RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY

See Also:

• Constant Field Values

RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY_DEFAULT

public static final boolean RS_ENABLE_SERVER_QUERY_METER_METRICS_KEY_DEFAULT

See Also:

• Constant Field Values

SLOW_METRIC_TIME

public static final String SLOW_METRIC_TIME

See Also:

• Constant Field Values

serverSource

private final MetricsRegionServerSource serverSource

regionServerWrapper

private final MetricsRegionServerWrapper regionServerWrapper

metricsTable

private final MetricsTable metricsTable

quotaSource

private MetricsRegionServerQuotaSource quotaSource

userAggregate

private final MetricsUserAggregate userAggregate

metricRegistry

private MetricRegistry metricRegistry

bulkLoadTimer

private Timer bulkLoadTimer

serverReadQueryMeter

private Meter serverReadQueryMeter

serverWriteQueryMeter

private Meter serverWriteQueryMeter

slowMetricTime

protected long slowMetricTime

DEFAULT_SLOW_METRIC_TIME

protected static final int DEFAULT_SLOW_METRIC_TIME

See Also:

• Constant Field Values

Constructor Details

MetricsRegionServer

public MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper,
 org.apache.hadoop.conf.Configuration conf,
 MetricsTable metricsTable)

MetricsRegionServer

MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper,
 MetricsRegionServerSource serverSource,
 MetricsTable metricsTable,
 MetricsUserAggregate userAggregate)

Method Details

getMetricsSource

public MetricsRegionServerSource getMetricsSource()

getMetricsUserAggregate

public MetricsUserAggregate getMetricsUserAggregate()

getRegionServerWrapper

public MetricsRegionServerWrapper getRegionServerWrapper()

updatePutBatch

public void updatePutBatch(HRegion region,
 long t)

updatePut

public void updatePut(HRegion region,
 long t)

updateDelete

public void updateDelete(HRegion region,
 long t)

updateDeleteBatch

public void updateDeleteBatch(HRegion region,
 long t)

updateCheckAndDelete

public void updateCheckAndDelete(HRegion region,
 long t)

updateCheckAndPut

public void updateCheckAndPut(HRegion region,
 long t)

updateCheckAndMutate

public void updateCheckAndMutate(HRegion region,
 long time,
 long blockBytesScanned)

updateGet

public void updateGet(HRegion region,
 long time,
 long blockBytesScanned)

updateIncrement

public void updateIncrement(HRegion region,
 long time,
 long blockBytesScanned)

updateAppend

public void updateAppend(HRegion region,
 long time,
 long blockBytesScanned)

updateReplay

public void updateReplay(long t)

updateScan

public void updateScan(HRegion region,
 long time,
 long responseCellSize,
 long blockBytesScanned)

updateSplitTime

public void updateSplitTime(long t)

incrSplitRequest

public void incrSplitRequest()

incrSplitSuccess

public void incrSplitSuccess()

updateFlush

public void updateFlush(String table,
 long t,
 long memstoreSize,
 long fileSize)

updateCompaction

public void updateCompaction(String table,
 boolean isMajor,
 long t,
 int inputFileCount,
 int outputFileCount,
 long inputBytes,
 long outputBytes)

updateBulkLoad

public void updateBulkLoad(long millis)

incrementNumRegionSizeReportsSent

public void incrementNumRegionSizeReportsSent(long numReportsSent)

See Also:

• MetricsRegionServerQuotaSource.incrementNumRegionSizeReportsSent(long)

incrementRegionSizeReportingChoreTime

public void incrementRegionSizeReportingChoreTime(long time)

See Also:

• MetricsRegionServerQuotaSource.incrementRegionSizeReportingChoreTime(long)

updateReadQueryMeter

public void updateReadQueryMeter(HRegion region,
 long count)

updateWriteQueryMeter

public void updateWriteQueryMeter(HRegion region,
 long count)

updateWriteQueryMeter

public void updateWriteQueryMeter(HRegion region)

incrScannerLeaseExpired

public void incrScannerLeaseExpired()