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 MetricsRegionServerWrapper	regionServerWrapper
static boolean	RS_ENABLE_TABLE_METRICS_DEFAULT
static String	RS_ENABLE_TABLE_METRICS_KEY
private MetricsRegionServerSource	serverSource
private RegionServerTableMetrics	tableMetrics

Constructor Summary

Constructors

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

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()
MetricsRegionServerWrapper	getRegionServerWrapper()
void	incrSplitRequest()
void	incrSplitSuccess()
void	updateAppend(TableName tn, long t)
void	updateBulkLoad(long millis)
void	updateCheckAndDelete(long t)
void	updateCheckAndPut(long t)
void	updateCompaction(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(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	updateReplay(long t)
void	updateScanSize(TableName tn, long scanSize)
void	updateScanTime(TableName tn, long t)
void	updateSplitTime(long t)

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 MetricsRegionServerSource serverSource

regionServerWrapper

private MetricsRegionServerWrapper regionServerWrapper

tableMetrics

private RegionServerTableMetrics tableMetrics

metricRegistry

private MetricRegistry metricRegistry

bulkLoadTimer

private Timer bulkLoadTimer

Constructor Detail

MetricsRegionServer

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

MetricsRegionServer

MetricsRegionServer(MetricsRegionServerWrapper regionServerWrapper,
                    MetricsRegionServerSource serverSource,
                    RegionServerTableMetrics tableMetrics)

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

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

updateCompaction

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

updateBulkLoad

public void updateBulkLoad(long millis)