org.apache.hadoop.hbase.regionserver

Class MetricsRegionServer

java.lang.Object

org.apache.hadoop.hbase.regionserver.MetricsRegionServer

@InterfaceStability.Evolving
 @InterfaceAudience.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 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
static boolean	RS_ENABLE_TABLE_METRICS_DEFAULT
static String	RS_ENABLE_TABLE_METRICS_KEY
static String	RS_ENABLE_TABLE_QUERY_METER_METRICS_KEY
static boolean	RS_ENABLE_TABLE_QUERY_METER_METRICS_KEY_DEFAULT
private Meter	serverReadQueryMeter
private MetricsRegionServerSource	serverSource
private Meter	serverWriteQueryMeter
static String	SLOW_METRIC_TIME
protected long	slowMetricTime
private RegionServerTableMetrics	tableMetrics
private MetricsUserAggregate	userAggregate

Constructor Summary

Constructors

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

Method Summary

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()
MetricsUserAggregate	getMetricsUserAggregate()
MetricsRegionServerWrapper	getRegionServerWrapper()
void	incrementNumRegionSizeReportsSent(long numReportsSent)
void	incrementRegionSizeReportingChoreTime(long time)
void	incrScannerLeaseExpired()
void	incrSplitRequest()
void	incrSplitSuccess()
void	updateAppend(TableName tn, long t)
void	updateBulkLoad(long millis)
void	updateCheckAndDelete(TableName tn, long t)
void	updateCheckAndMutate(TableName tn, long t)
void	updateCheckAndPut(TableName tn, long t)
void	updateCompaction(String table, 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(String table, 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, 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)

Methods inherited from class java.lang.Object

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

Field Detail

RS_ENABLE_TABLE_METRICS_KEY

public static final String RS_ENABLE_TABLE_METRICS_KEY

See Also:

Constant Field Values

RS_ENABLE_TABLE_METRICS_DEFAULT

public static final boolean RS_ENABLE_TABLE_METRICS_DEFAULT

See Also:

Constant Field Values

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

RS_ENABLE_TABLE_QUERY_METER_METRICS_KEY

public static final String RS_ENABLE_TABLE_QUERY_METER_METRICS_KEY

See Also:

Constant Field Values

RS_ENABLE_TABLE_QUERY_METER_METRICS_KEY_DEFAULT

public static final boolean RS_ENABLE_TABLE_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

tableMetrics

private RegionServerTableMetrics tableMetrics

metricsTable

private final MetricsTable metricsTable

userAggregate

private final MetricsUserAggregate userAggregate

quotaSource

private MetricsRegionServerQuotaSource quotaSource

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 Detail

MetricsRegionServer

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

MetricsRegionServer

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

Method Detail

createTableMetrics

static RegionServerTableMetrics createTableMetrics(org.apache.hadoop.conf.Configuration conf)

Creates an instance of RegionServerTableMetrics only if the feature is enabled.

getMetricsSource

public MetricsRegionServerSource getMetricsSource()

getMetricsUserAggregate

public MetricsUserAggregate getMetricsUserAggregate()

getRegionServerWrapper

public MetricsRegionServerWrapper getRegionServerWrapper()

updatePutBatch

public void updatePutBatch(TableName tn,
                           long t)

updatePut

public void updatePut(TableName tn,
                      long t)

updateDelete

public void updateDelete(TableName tn,
                         long t)

updateDeleteBatch

public void updateDeleteBatch(TableName tn,
                              long t)

updateCheckAndDelete

public void updateCheckAndDelete(TableName tn,
                                 long t)

updateCheckAndPut

public void updateCheckAndPut(TableName tn,
                              long t)

updateCheckAndMutate

public void updateCheckAndMutate(TableName tn,
                                 long t)

updateGet

public void updateGet(TableName tn,
                      long t)

updateIncrement

public void updateIncrement(TableName tn,
                            long t)

updateAppend

public void updateAppend(TableName tn,
                         long t)

updateReplay

public void updateReplay(long t)

updateScanSize

public void updateScanSize(TableName tn,
                           long scanSize)

updateScanTime

public void updateScanTime(TableName tn,
                           long t)

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)

updateReadQueryMeter

public void updateReadQueryMeter(TableName tn,
                                 long count)

updateWriteQueryMeter

public void updateWriteQueryMeter(TableName tn,
                                  long count)

updateWriteQueryMeter

public void updateWriteQueryMeter(TableName tn)

incrementNumRegionSizeReportsSent

public void incrementNumRegionSizeReportsSent(long numReportsSent)

See Also:

MetricsRegionServerQuotaSource.incrementNumRegionSizeReportsSent(long)

incrementRegionSizeReportingChoreTime

public void incrementRegionSizeReportingChoreTime(long time)

See Also:

MetricsRegionServerQuotaSource.incrementRegionSizeReportingChoreTime(long)

incrScannerLeaseExpired

public void incrScannerLeaseExpired()