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

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.

Field Summary

Fields

Modifier and Type	Field and Description
private Timer	bulkLoadTimer
private MetricRegistry	metricRegistry
private MetricsTable	metricsTable
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
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	incrSplitRequest()
void	incrSplitSuccess()
void	updateAppend(TableName tn, long t)
void	updateBulkLoad(long millis)
void	updateCheckAndDelete(long t)
void	updateCheckAndPut(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)
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

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

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(long t)

updateCheckAndPut

public void updateCheckAndPut(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)

updateReadQueryMeter

public void updateReadQueryMeter(TableName tn)

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)