Package org.apache.hadoop.hbase.regionserver.metrics

Class MetricsTableRequests

java.lang.Object

org.apache.hadoop.hbase.regionserver.metrics.MetricsTableRequests

@Private
public class MetricsTableRequests
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
(package private) String	APPEND_BLOCK_BYTES_SCANNED_KEY
private static final String	APPEND_TIME
private Histogram	appendBlockBytesScanned
private Histogram	appendTimeHistogram
(package private) String	BLOCK_BYTES_SCANNED_KEY
private Counter	blockBytesScannedCount
private static final String	CHECK_AND_DELETE_TIME
(package private) String	CHECK_AND_MUTATE_BLOCK_BYTES_SCANNED_KEY
private static final String	CHECK_AND_MUTATE_TIME
private static final String	CHECK_AND_PUT_TIME
private Histogram	checkAndDeleteTimeHistogram
private Histogram	checkAndMutateBlockBytesScanned
private Histogram	checkAndMutateTimeHistogram
private Histogram	checkAndPutTimeHistogram
private org.apache.hadoop.conf.Configuration	conf
private static final String	DELETE_BATCH_TIME
private static final String	DELETE_TIME
private Histogram	deleteBatchTimeHistogram
private Histogram	deleteTimeHistogram
static final boolean	ENABLE_TABLE_LATENCIES_METRICS_DEFAULT
static final String	ENABLE_TABLE_LATENCIES_METRICS_KEY
static final String	ENABLE_TABLE_QUERY_METER_METRICS_KEY
static final boolean	ENABLE_TABLE_QUERY_METER_METRICS_KEY_DEFAULT
private boolean	enableTableLatenciesMetrics
private boolean	enabTableQueryMeterMetrics
(package private) String	GET_BLOCK_BYTES_SCANNED_KEY
private static final String	GET_TIME
private Histogram	getBlockBytesScanned
private Histogram	getTimeHistogram
(package private) String	INCREMENT_BLOCK_BYTES_SCANNED_KEY
private static final String	INCREMENT_TIME
private Histogram	incrementBlockBytesScanned
private Histogram	incrementTimeHistogram
private static final String	METRICS_CONTEXT	The name of the metrics context that metrics will be under.
private static final String	METRICS_DESCRIPTION	Description
private static final String	METRICS_JMX_CONTEXT	The name of the metrics context that metrics will be under in jmx
private static final String	METRICS_NAME	The name of the metrics
private static final String	PUT_BATCH_TIME
private static final String	PUT_TIME
private Histogram	putBatchTimeHistogram
private Histogram	putTimeHistogram
private Meter	readMeter
private MetricRegistry	registry
private MetricRegistryInfo	registryInfo
(package private) String	SCAN_BLOCK_BYTES_SCANNED_KEY
private static final String	SCAN_SIZE
private static final String	SCAN_TIME
private Histogram	scanBlockBytesScanned
private Histogram	scanSizeHistogram
private Histogram	scanTimeHistogram
private static final String	TABLE_READ_QUERY_PER_SECOND
private static final String	TABLE_WRITE_QUERY_PER_SECOND
private TableName	tableName
private Meter	writeMeter

Constructor Summary

Constructors

Constructor	Description
MetricsTableRequests(TableName tableName, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
private MetricRegistry	createRegistryForTableRequests()
private MetricRegistryInfo	createRegistryInfoForTableRequests()
MetricRegistryInfo	getMetricRegistryInfo()
private void	init(TableName tableName, org.apache.hadoop.conf.Configuration conf)
boolean	isEnableTableLatenciesMetrics()
boolean	isEnabTableQueryMeterMetrics()
private static String	qualifyMetrics(String prefix, TableName tableName)
void	removeRegistry()
void	updateAppend(long time, long blockBytesScanned)	Update the Append time histogram.
void	updateCheckAndDelete(long time)	Update the CheckAndDelete time histogram.
void	updateCheckAndMutate(long time, long blockBytesScanned)	Update the CheckAndMutate time histogram.
void	updateCheckAndPut(long time)	Update the CheckAndPut time histogram.
void	updateDelete(long t)	Update the Delete time histogram
void	updateDeleteBatch(long t)	Update the batch Delete time histogram
void	updateGet(long time, long blockBytesScanned)	Update the Get time histogram .
void	updateIncrement(long time, long blockBytesScanned)	Update the Increment time histogram.
void	updatePut(long t)	Update the Put time histogram
void	updatePutBatch(long t)	Update the batch Put time histogram
void	updateScan(long time, long responseCellSize, long blockBytesScanned)	Update the scan metrics.
void	updateTableReadQueryMeter()	Update table read QPS
void	updateTableReadQueryMeter(long count)	Update table read QPS
void	updateTableWriteQueryMeter()	Update table write QPS
void	updateTableWriteQueryMeter(long count)	Update table write QPS

Methods inherited from class java.lang.Object

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

Field Details

ENABLE_TABLE_LATENCIES_METRICS_KEY

public static final String ENABLE_TABLE_LATENCIES_METRICS_KEY

See Also:

• Constant Field Values

ENABLE_TABLE_LATENCIES_METRICS_DEFAULT

public static final boolean ENABLE_TABLE_LATENCIES_METRICS_DEFAULT

See Also:

• Constant Field Values

ENABLE_TABLE_QUERY_METER_METRICS_KEY

public static final String ENABLE_TABLE_QUERY_METER_METRICS_KEY

See Also:

• Constant Field Values

ENABLE_TABLE_QUERY_METER_METRICS_KEY_DEFAULT

public static final boolean ENABLE_TABLE_QUERY_METER_METRICS_KEY_DEFAULT

See Also:

• Constant Field Values

METRICS_NAME

private static final String METRICS_NAME

The name of the metrics

See Also:

• Constant Field Values

METRICS_CONTEXT

private static final String METRICS_CONTEXT

The name of the metrics context that metrics will be under.

See Also:

• Constant Field Values

METRICS_DESCRIPTION

private static final String METRICS_DESCRIPTION

Description

See Also:

• Constant Field Values

METRICS_JMX_CONTEXT

private static final String METRICS_JMX_CONTEXT

The name of the metrics context that metrics will be under in jmx

See Also:

• Constant Field Values

GET_TIME

private static final String GET_TIME

See Also:

• Constant Field Values

SCAN_TIME

private static final String SCAN_TIME

See Also:

• Constant Field Values

SCAN_SIZE

private static final String SCAN_SIZE

See Also:

• Constant Field Values

PUT_TIME

private static final String PUT_TIME

See Also:

• Constant Field Values

PUT_BATCH_TIME

private static final String PUT_BATCH_TIME

See Also:

• Constant Field Values

DELETE_TIME

private static final String DELETE_TIME

See Also:

• Constant Field Values

DELETE_BATCH_TIME

private static final String DELETE_BATCH_TIME

See Also:

• Constant Field Values

INCREMENT_TIME

private static final String INCREMENT_TIME

See Also:

• Constant Field Values

APPEND_TIME

private static final String APPEND_TIME

See Also:

• Constant Field Values

CHECK_AND_DELETE_TIME

private static final String CHECK_AND_DELETE_TIME

See Also:

• Constant Field Values

CHECK_AND_PUT_TIME

private static final String CHECK_AND_PUT_TIME

See Also:

• Constant Field Values

CHECK_AND_MUTATE_TIME

private static final String CHECK_AND_MUTATE_TIME

See Also:

• Constant Field Values

BLOCK_BYTES_SCANNED_KEY

String BLOCK_BYTES_SCANNED_KEY

GET_BLOCK_BYTES_SCANNED_KEY

String GET_BLOCK_BYTES_SCANNED_KEY

SCAN_BLOCK_BYTES_SCANNED_KEY

String SCAN_BLOCK_BYTES_SCANNED_KEY

CHECK_AND_MUTATE_BLOCK_BYTES_SCANNED_KEY

String CHECK_AND_MUTATE_BLOCK_BYTES_SCANNED_KEY

INCREMENT_BLOCK_BYTES_SCANNED_KEY

String INCREMENT_BLOCK_BYTES_SCANNED_KEY

APPEND_BLOCK_BYTES_SCANNED_KEY

String APPEND_BLOCK_BYTES_SCANNED_KEY

TABLE_READ_QUERY_PER_SECOND

private static final String TABLE_READ_QUERY_PER_SECOND

See Also:

• Constant Field Values

TABLE_WRITE_QUERY_PER_SECOND

private static final String TABLE_WRITE_QUERY_PER_SECOND

See Also:

• Constant Field Values

getTimeHistogram

private Histogram getTimeHistogram

scanTimeHistogram

private Histogram scanTimeHistogram

scanSizeHistogram

private Histogram scanSizeHistogram

putTimeHistogram

private Histogram putTimeHistogram

putBatchTimeHistogram

private Histogram putBatchTimeHistogram

deleteTimeHistogram

private Histogram deleteTimeHistogram

deleteBatchTimeHistogram

private Histogram deleteBatchTimeHistogram

incrementTimeHistogram

private Histogram incrementTimeHistogram

appendTimeHistogram

private Histogram appendTimeHistogram

checkAndDeleteTimeHistogram

private Histogram checkAndDeleteTimeHistogram

checkAndPutTimeHistogram

private Histogram checkAndPutTimeHistogram

checkAndMutateTimeHistogram

private Histogram checkAndMutateTimeHistogram

blockBytesScannedCount

private Counter blockBytesScannedCount

checkAndMutateBlockBytesScanned

private Histogram checkAndMutateBlockBytesScanned

getBlockBytesScanned

private Histogram getBlockBytesScanned

incrementBlockBytesScanned

private Histogram incrementBlockBytesScanned

appendBlockBytesScanned

private Histogram appendBlockBytesScanned

scanBlockBytesScanned

private Histogram scanBlockBytesScanned

readMeter

private Meter readMeter

writeMeter

private Meter writeMeter

registry

private MetricRegistry registry

tableName

private TableName tableName

conf

private org.apache.hadoop.conf.Configuration conf

registryInfo

private MetricRegistryInfo registryInfo

enableTableLatenciesMetrics

private boolean enableTableLatenciesMetrics

enabTableQueryMeterMetrics

private boolean enabTableQueryMeterMetrics

Constructor Details

MetricsTableRequests

public MetricsTableRequests(TableName tableName,
 org.apache.hadoop.conf.Configuration conf)

Method Details

isEnableTableLatenciesMetrics

public boolean isEnableTableLatenciesMetrics()

isEnabTableQueryMeterMetrics

public boolean isEnabTableQueryMeterMetrics()

init

private void init(TableName tableName,
 org.apache.hadoop.conf.Configuration conf)

createRegistryForTableRequests

private MetricRegistry createRegistryForTableRequests()

createRegistryInfoForTableRequests

private MetricRegistryInfo createRegistryInfoForTableRequests()

removeRegistry

public void removeRegistry()

qualifyMetrics

private static String qualifyMetrics(String prefix,
 TableName tableName)

updatePut

public void updatePut(long t)

Update the Put time histogram

Parameters:

t - time it took

updatePutBatch

public void updatePutBatch(long t)

Update the batch Put time histogram

Parameters:

t - time it took

updateDelete

public void updateDelete(long t)

Update the Delete time histogram

Parameters:

t - time it took

updateDeleteBatch

public void updateDeleteBatch(long t)

Update the batch Delete time histogram

Parameters:

t - time it took

updateGet

public void updateGet(long time,
 long blockBytesScanned)

Update the Get time histogram .

Parameters:

time - time it took

blockBytesScanned - size of block bytes scanned to retrieve the response

updateIncrement

public void updateIncrement(long time,
 long blockBytesScanned)

Update the Increment time histogram.

Parameters:

time - time it took

blockBytesScanned - size of block bytes scanned to retrieve the response

updateAppend

public void updateAppend(long time,
 long blockBytesScanned)

Update the Append time histogram.

Parameters:

time - time it took

blockBytesScanned - size of block bytes scanned to retrieve the response

updateScan

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

Update the scan metrics.

Parameters:

time - response time of scan

responseCellSize - size of the scan resposne

blockBytesScanned - size of block bytes scanned to retrieve the response

updateCheckAndDelete

public void updateCheckAndDelete(long time)

Update the CheckAndDelete time histogram.

Parameters:

time - time it took

updateCheckAndPut

public void updateCheckAndPut(long time)

Update the CheckAndPut time histogram.

Parameters:

time - time it took

updateCheckAndMutate

public void updateCheckAndMutate(long time,
 long blockBytesScanned)

Update the CheckAndMutate time histogram.

Parameters:

time - time it took

updateTableReadQueryMeter

public void updateTableReadQueryMeter(long count)

Update table read QPS

Parameters:

count - Number of occurrences to record

updateTableReadQueryMeter

public void updateTableReadQueryMeter()

Update table read QPS

updateTableWriteQueryMeter

public void updateTableWriteQueryMeter(long count)

Update table write QPS

Parameters:

count - Number of occurrences to record

updateTableWriteQueryMeter

public void updateTableWriteQueryMeter()

Update table write QPS

getMetricRegistryInfo

public MetricRegistryInfo getMetricRegistryInfo()