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
protected static int	DEFAULT_SLOW_METRIC_TIME
static boolean	RS_ENABLE_TABLE_METRICS_DEFAULT
static String	RS_ENABLE_TABLE_METRICS_KEY
static String	SLOW_METRIC_TIME
protected long	slowMetricTime

Constructor Summary

Constructors

Constructor and Description
MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper, org.apache.hadoop.conf.Configuration conf, MetricsTable metricsTable)

Method Summary

Modifier and Type	Method and Description
MetricsRegionServerSource	getMetricsSource()
MetricsUserAggregate	getMetricsUserAggregate()
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(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

SLOW_METRIC_TIME

public static final String SLOW_METRIC_TIME

See Also:

Constant Field Values

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)

Method Detail

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)