Package org.apache.hadoop.hbase.regionserver

Class MetricsRegionServerSourceImpl

java.lang.Object

org.apache.hadoop.hbase.metrics.BaseSourceImpl

org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceImpl

All Implemented Interfaces:

BaseSource, JvmPauseMonitorSource, MetricsRegionServerSource, org.apache.hadoop.metrics2.MetricsSource

@Private
public class MetricsRegionServerSourceImpl
extends BaseSourceImpl
implements MetricsRegionServerSource

Hadoop2 implementation of MetricsRegionServerSource. Implements BaseSource through BaseSourceImpl, following the pattern

Field Summary

Fields

Modifier and Type	Field	Description
private final MetricHistogram	appendBlockBytesScanned
private final MetricHistogram	appendHisto
private final MutableFastCounter	blockBytesScannedCount
private final MetricHistogram	checkAndDeleteHisto
private final MetricHistogram	checkAndMutateBlockBytesScanned
private final MetricHistogram	checkAndMutateHisto
private final MetricHistogram	checkAndPutHisto
private final MutableFastCounter	compactedInputBytes
private final MutableFastCounter	compactedOutputBytes
private final MetricHistogram	compactionInputFileCountHisto
private final MetricHistogram	compactionInputSizeHisto
private final MetricHistogram	compactionOutputFileCountHisto
private final MetricHistogram	compactionOutputSizeHisto
private final MetricHistogram	compactionTimeHisto
private final MetricHistogram	deleteBatchHisto
private final MetricHistogram	deleteHisto
private final MutableFastCounter	flushedMemstoreBytes
private final MutableFastCounter	flushedOutputBytes
private final MetricHistogram	flushMemstoreSizeHisto
private final MetricHistogram	flushOutputSizeHisto
private final MetricHistogram	flushTimeHisto
private final MetricHistogram	getBlockBytesScanned
private final MetricHistogram	getHisto
private final MetricHistogram	incrementBlockBytesScanned
private final MetricHistogram	incrementHisto
private final MutableFastCounter	infoPauseThresholdExceeded
private final MutableFastCounter	majorCompactedInputBytes
private final MutableFastCounter	majorCompactedOutputBytes
private final MetricHistogram	majorCompactionInputFileCountHisto
private final MetricHistogram	majorCompactionInputSizeHisto
private final MetricHistogram	majorCompactionOutputFileCountHisto
private final MetricHistogram	majorCompactionOutputSizeHisto
private final MetricHistogram	majorCompactionTimeHisto
private final MetricHistogram	pausesWithGc
private final MetricHistogram	pausesWithoutGc
private final MetricHistogram	putBatchHisto
private final MetricHistogram	putHisto
private final MetricHistogram	replayHisto
(package private) final MetricsRegionServerWrapper	rsWrap
private final MetricHistogram	scanBlockBytesScanned
private final MutableFastCounter	scannerLeaseExpiredCount
private final MetricHistogram	scanSizeHisto
private final MetricHistogram	scanTimeHisto
private final MutableFastCounter	slowAppend
private final MutableFastCounter	slowDelete
private final MutableFastCounter	slowGet
private final MutableFastCounter	slowIncrement
private final MutableFastCounter	slowPut
private final MutableFastCounter	splitRequest
private final MutableFastCounter	splitSuccess
private final MetricHistogram	splitTimeHisto
private final MutableFastCounter	warnPauseThresholdExceeded

Fields inherited from class org.apache.hadoop.hbase.metrics.BaseSourceImpl

metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registry

Fields inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

HBASE_METRICS_SYSTEM_NAME

Fields inherited from interface org.apache.hadoop.hbase.metrics.JvmPauseMonitorSource

INFO_THRESHOLD_COUNT_DESC, INFO_THRESHOLD_COUNT_KEY, PAUSE_TIME_WITH_GC_DESC, PAUSE_TIME_WITH_GC_KEY, PAUSE_TIME_WITHOUT_GC_DESC, PAUSE_TIME_WITHOUT_GC_KEY, WARN_THRESHOLD_COUNT_DESC, WARN_THRESHOLD_COUNT_KEY

Fields inherited from interface org.apache.hadoop.hbase.regionserver.MetricsRegionServerSource

ACTIVE_SCANNERS, ACTIVE_SCANNERS_DESC, APPEND_BLOCK_BYTES_SCANNED_KEY, APPEND_KEY, AVERAGE_REGION_SIZE, AVERAGE_REGION_SIZE_DESC, AVG_STORE_FILE_AGE, AVG_STORE_FILE_AGE_DESC, BLOCK_BYTES_SCANNED_DESC, BLOCK_BYTES_SCANNED_KEY, BLOCK_CACHE_BLOOM_CHUNK_HIT_COUNT, BLOCK_CACHE_BLOOM_CHUNK_MISS_COUNT, BLOCK_CACHE_COUNT, BLOCK_CACHE_COUNT_DESC, BLOCK_CACHE_DATA_BLOCK_COUNT, BLOCK_CACHE_DATA_BLOCK_COUNT_DESC, BLOCK_CACHE_DATA_HIT_COUNT, BLOCK_CACHE_DATA_MISS_COUNT, BLOCK_CACHE_DELETE_FAMILY_BLOOM_HIT_COUNT, BLOCK_CACHE_DELETE_FAMILY_BLOOM_MISS_COUNT, BLOCK_CACHE_ENCODED_DATA_HIT_COUNT, BLOCK_CACHE_ENCODED_DATA_MISS_COUNT, BLOCK_CACHE_EVICTION_COUNT, BLOCK_CACHE_EVICTION_COUNT_DESC, BLOCK_CACHE_EXPRESS_HIT_PERCENT, BLOCK_CACHE_EXPRESS_HIT_PERCENT_DESC, BLOCK_CACHE_FAILED_INSERTION_COUNT, BLOCK_CACHE_FAILED_INSERTION_COUNT_DESC, BLOCK_CACHE_FILE_INFO_HIT_COUNT, BLOCK_CACHE_FILE_INFO_MISS_COUNT, BLOCK_CACHE_FREE_DESC, BLOCK_CACHE_FREE_SIZE, BLOCK_CACHE_GENERAL_BLOOM_META_HIT_COUNT, BLOCK_CACHE_GENERAL_BLOOM_META_MISS_COUNT, BLOCK_CACHE_HIT_CACHING_COUNT, BLOCK_CACHE_HIT_CACHING_COUNT_DESC, BLOCK_CACHE_HIT_COUNT, BLOCK_CACHE_HIT_COUNT_DESC, BLOCK_CACHE_HIT_PERCENT, BLOCK_CACHE_HIT_PERCENT_DESC, BLOCK_CACHE_INTERMEDIATE_INDEX_HIT_COUNT, BLOCK_CACHE_INTERMEDIATE_INDEX_MISS_COUNT, BLOCK_CACHE_LEAF_INDEX_HIT_COUNT, BLOCK_CACHE_LEAF_INDEX_MISS_COUNT, BLOCK_CACHE_META_HIT_COUNT, BLOCK_CACHE_META_MISS_COUNT, BLOCK_CACHE_MISS_CACHING_COUNT, BLOCK_CACHE_MISS_COUNT, BLOCK_CACHE_PRIMARY_EVICTION_COUNT, BLOCK_CACHE_PRIMARY_EVICTION_COUNT_DESC, BLOCK_CACHE_PRIMARY_HIT_COUNT, BLOCK_CACHE_PRIMARY_HIT_COUNT_DESC, BLOCK_CACHE_PRIMARY_MISS_COUNT, BLOCK_CACHE_ROOT_INDEX_HIT_COUNT, BLOCK_CACHE_ROOT_INDEX_MISS_COUNT, BLOCK_CACHE_SIZE, BLOCK_CACHE_SIZE_DESC, BLOCK_CACHE_TRAILER_HIT_COUNT, BLOCK_CACHE_TRAILER_MISS_COUNT, BLOCK_COUNT_MISS_CACHING_COUNT_DESC, BLOCK_COUNT_MISS_COUNT_DESC, BLOCK_COUNT_PRIMARY_MISS_COUNT_DESC, BLOCKED_REQUESTS_COUNT, BLOCKED_REQUESTS_COUNT_DESC, BLOOM_FILTER_ELIGIBLE_REQUESTS_COUNT, BLOOM_FILTER_ELIGIBLE_REQUESTS_COUNT_DESC, BLOOM_FILTER_NEGATIVE_RESULTS_COUNT, BLOOM_FILTER_NEGATIVE_RESULTS_COUNT_DESC, BLOOM_FILTER_REQUESTS_COUNT, BLOOM_FILTER_REQUESTS_COUNT_DESC, BYTE_BUFF_ALLOCATOR_HEAP_ALLOCATION_BYTES, BYTE_BUFF_ALLOCATOR_HEAP_ALLOCATION_BYTES_DESC, BYTE_BUFF_ALLOCATOR_HEAP_ALLOCATION_RATIO, BYTE_BUFF_ALLOCATOR_HEAP_ALLOCATION_RATIO_DESC, BYTE_BUFF_ALLOCATOR_POOL_ALLOCATION_BYTES, BYTE_BUFF_ALLOCATOR_POOL_ALLOCATION_BYTES_DESC, BYTE_BUFF_ALLOCATOR_TOTAL_BUFFER_COUNT, BYTE_BUFF_ALLOCATOR_TOTAL_BUFFER_COUNT_DESC, BYTE_BUFF_ALLOCATOR_USED_BUFFER_COUNT, BYTE_BUFF_ALLOCATOR_USED_BUFFER_COUNT_DESC, CELLS_COUNT_COMPACTED_FROM_MOB, CELLS_COUNT_COMPACTED_FROM_MOB_DESC, CELLS_COUNT_COMPACTED_TO_MOB, CELLS_COUNT_COMPACTED_TO_MOB_DESC, CELLS_SIZE_COMPACTED_FROM_MOB, CELLS_SIZE_COMPACTED_FROM_MOB_DESC, CELLS_SIZE_COMPACTED_TO_MOB, CELLS_SIZE_COMPACTED_TO_MOB_DESC, CHECK_AND_DELETE_KEY, CHECK_AND_MUTATE_BLOCK_BYTES_SCANNED_KEY, CHECK_AND_MUTATE_KEY, CHECK_AND_PUT_KEY, CHECK_MUTATE_FAILED_COUNT, CHECK_MUTATE_FAILED_COUNT_DESC, CHECK_MUTATE_PASSED_COUNT, CHECK_MUTATE_PASSED_COUNT_DESC, CLUSTER_ID_DESC, CLUSTER_ID_NAME, COMPACTED_CELLS, COMPACTED_CELLS_DESC, COMPACTED_CELLS_SIZE, COMPACTED_CELLS_SIZE_DESC, COMPACTED_INPUT_BYTES, COMPACTED_INPUT_BYTES_DESC, COMPACTED_OUTPUT_BYTES, COMPACTED_OUTPUT_BYTES_DESC, COMPACTION_INPUT_FILE_COUNT, COMPACTION_INPUT_FILE_COUNT_DESC, COMPACTION_INPUT_SIZE, COMPACTION_INPUT_SIZE_DESC, COMPACTION_OUTPUT_FILE_COUNT, COMPACTION_OUTPUT_FILE_COUNT_DESC, COMPACTION_OUTPUT_SIZE, COMPACTION_OUTPUT_SIZE_DESC, COMPACTION_QUEUE_LENGTH, COMPACTION_QUEUE_LENGTH_DESC, COMPACTION_TIME, COMPACTION_TIME_DESC, CP_REQUEST_COUNT, CP_REQUEST_COUNT_DESC, CURRENT_REGION_CACHE_RATIO, CURRENT_REGION_CACHE_RATIO_DESC, DATA_SIZE_WITHOUT_WAL, DATA_SIZE_WITHOUT_WAL_DESC, DELETE_BATCH_KEY, DELETE_KEY, FILTERED_READ_REQUEST_COUNT, FILTERED_READ_REQUEST_COUNT_DESC, FLUSH_MEMSTORE_SIZE, FLUSH_MEMSTORE_SIZE_DESC, FLUSH_OUTPUT_SIZE, FLUSH_OUTPUT_SIZE_DESC, FLUSH_QUEUE_LENGTH, FLUSH_QUEUE_LENGTH_DESC, FLUSH_TIME, FLUSH_TIME_DESC, FLUSHED_CELLS, FLUSHED_CELLS_DESC, FLUSHED_CELLS_SIZE, FLUSHED_CELLS_SIZE_DESC, FLUSHED_MEMSTORE_BYTES, FLUSHED_MEMSTORE_BYTES_DESC, FLUSHED_OUTPUT_BYTES, FLUSHED_OUTPUT_BYTES_DESC, GET_BLOCK_BYTES_SCANNED_KEY, GET_KEY, GET_SIZE_KEY, HEDGED_READ_IN_CUR_THREAD, HEDGED_READ_IN_CUR_THREAD_DESC, HEDGED_READ_WINS, HEDGED_READ_WINS_DESC, HEDGED_READS, HEDGED_READS_DESC, INCREMENT_BLOCK_BYTES_SCANNED_KEY, INCREMENT_KEY, L1_CACHE_COUNT, L1_CACHE_COUNT_DESC, L1_CACHE_EVICTION_COUNT, L1_CACHE_EVICTION_COUNT_DESC, L1_CACHE_FREE_SIZE, L1_CACHE_FREE_SIZE_DESC, L1_CACHE_HIT_COUNT, L1_CACHE_HIT_COUNT_DESC, L1_CACHE_HIT_RATIO, L1_CACHE_HIT_RATIO_DESC, L1_CACHE_MISS_COUNT, L1_CACHE_MISS_COUNT_DESC, L1_CACHE_MISS_RATIO, L1_CACHE_MISS_RATIO_DESC, L1_CACHE_SIZE, L1_CACHE_SIZE_DESC, L2_CACHE_COUNT, L2_CACHE_COUNT_DESC, L2_CACHE_EVICTION_COUNT, L2_CACHE_EVICTION_COUNT_DESC, L2_CACHE_FREE_SIZE, L2_CACHE_FREE_SIZE_DESC, L2_CACHE_HIT_COUNT, L2_CACHE_HIT_COUNT_DESC, L2_CACHE_HIT_RATIO, L2_CACHE_HIT_RATIO_DESC, L2_CACHE_MISS_COUNT, L2_CACHE_MISS_COUNT_DESC, L2_CACHE_MISS_RATIO, L2_CACHE_MISS_RATIO_DESC, L2_CACHE_SIZE, L2_CACHE_SIZE_DESC, LARGE_COMPACTION_QUEUE_LENGTH, LARGE_COMPACTION_QUEUE_LENGTH_DESC, LOCAL_BYTES_READ, LOCAL_BYTES_READ_DESC, MAJOR_COMPACTED_CELLS, MAJOR_COMPACTED_CELLS_DESC, MAJOR_COMPACTED_CELLS_SIZE, MAJOR_COMPACTED_CELLS_SIZE_DESC, MAJOR_COMPACTED_INPUT_BYTES, MAJOR_COMPACTED_INPUT_BYTES_DESC, MAJOR_COMPACTED_OUTPUT_BYTES, MAJOR_COMPACTED_OUTPUT_BYTES_DESC, MAJOR_COMPACTION_INPUT_FILE_COUNT, MAJOR_COMPACTION_INPUT_FILE_COUNT_DESC, MAJOR_COMPACTION_INPUT_SIZE, MAJOR_COMPACTION_INPUT_SIZE_DESC, MAJOR_COMPACTION_OUTPUT_FILE_COUNT, MAJOR_COMPACTION_OUTPUT_FILE_COUNT_DESC, MAJOR_COMPACTION_OUTPUT_SIZE, MAJOR_COMPACTION_OUTPUT_SIZE_DESC, MAJOR_COMPACTION_TIME, MAJOR_COMPACTION_TIME_DESC, MAX_COMPACTED_STORE_FILE_REF_COUNT, MAX_STORE_FILE_AGE, MAX_STORE_FILE_AGE_DESC, MAX_STOREFILE_COUNT, MAX_STOREFILE_COUNT_DESC, MEMSTORE_HEAP_SIZE, MEMSTORE_HEAP_SIZE_DESC, MEMSTORE_OFFHEAP_SIZE, MEMSTORE_OFFHEAP_SIZE_DESC, MEMSTORE_SIZE, MEMSTORE_SIZE_DESC, METRICS_CONTEXT, METRICS_DESCRIPTION, METRICS_JMX_CONTEXT, METRICS_NAME, MIN_STORE_FILE_AGE, MIN_STORE_FILE_AGE_DESC, MOB_FILE_CACHE_ACCESS_COUNT, MOB_FILE_CACHE_ACCESS_COUNT_DESC, MOB_FILE_CACHE_COUNT, MOB_FILE_CACHE_COUNT_DESC, MOB_FILE_CACHE_EVICTED_COUNT, MOB_FILE_CACHE_EVICTED_COUNT_DESC, MOB_FILE_CACHE_HIT_PERCENT, MOB_FILE_CACHE_HIT_PERCENT_DESC, MOB_FILE_CACHE_MISS_COUNT, MOB_FILE_CACHE_MISS_COUNT_DESC, MOB_FLUSH_COUNT, MOB_FLUSH_COUNT_DESC, MOB_FLUSHED_CELLS_COUNT, MOB_FLUSHED_CELLS_COUNT_DESC, MOB_FLUSHED_CELLS_SIZE, MOB_FLUSHED_CELLS_SIZE_DESC, MOB_SCAN_CELLS_COUNT, MOB_SCAN_CELLS_COUNT_DESC, MOB_SCAN_CELLS_SIZE, MOB_SCAN_CELLS_SIZE_DESC, NUM_REFERENCE_FILES, NUM_REFERENCE_FILES_DESC, NUMBER_OF_MUTATIONS_WITHOUT_WAL, NUMBER_OF_MUTATIONS_WITHOUT_WAL_DESC, PERCENT_FILES_LOCAL, PERCENT_FILES_LOCAL_DESC, PERCENT_FILES_LOCAL_SECONDARY_REGIONS, PERCENT_FILES_LOCAL_SECONDARY_REGIONS_DESC, PUT_BATCH_KEY, PUT_KEY, READ_REQUEST_COUNT, READ_REQUEST_COUNT_DESC, READ_REQUEST_RATE_DESC, READ_REQUEST_RATE_PER_SECOND, REGION_COUNT, REGION_COUNT_DESC, REPLAY_KEY, RPC_FULL_SCAN_REQUEST_COUNT, RPC_FULL_SCAN_REQUEST_COUNT_DESC, RPC_GET_REQUEST_COUNT, RPC_GET_REQUEST_COUNT_DESC, RPC_MULTI_REQUEST_COUNT, RPC_MULTI_REQUEST_COUNT_DESC, RPC_MUTATE_REQUEST_COUNT, RPC_MUTATE_REQUEST_COUNT_DESC, RPC_SCAN_REQUEST_COUNT, RPC_SCAN_REQUEST_COUNT_DESC, RS_START_TIME_DESC, RS_START_TIME_NAME, SCAN_BLOCK_BYTES_SCANNED_KEY, SCAN_KEY, SCAN_SIZE_KEY, SCAN_TIME_KEY, SCANNER_LEASE_EXPIRED_COUNT, SCANNER_LEASE_EXPIRED_COUNT_DESC, SERVER_NAME_DESC, SERVER_NAME_NAME, SHORTCIRCUIT_BYTES_READ, SHORTCIRCUIT_BYTES_READ_DESC, SLOW_APPEND_DESC, SLOW_APPEND_KEY, SLOW_DELETE_DESC, SLOW_DELETE_KEY, SLOW_GET_DESC, SLOW_GET_KEY, SLOW_INCREMENT_DESC, SLOW_INCREMENT_KEY, SLOW_PUT_DESC, SLOW_PUT_KEY, SMALL_COMPACTION_QUEUE_LENGTH, SMALL_COMPACTION_QUEUE_LENGTH_DESC, SPLIT_KEY, SPLIT_QUEUE_LENGTH, SPLIT_QUEUE_LENGTH_DESC, SPLIT_REQUEST_DESC, SPLIT_REQUEST_KEY, SPLIT_SUCCESS_DESC, SPLIT_SUCCESS_KEY, STATIC_BLOOM_SIZE, STATIC_BLOOM_SIZE_DESC, STATIC_INDEX_SIZE, STATIC_INDEX_SIZE_DESC, STORE_COUNT, STORE_COUNT_DESC, STORE_REF_COUNT, STORE_REF_COUNT_DESC, STOREFILE_COUNT, STOREFILE_COUNT_DESC, STOREFILE_INDEX_SIZE, STOREFILE_INDEX_SIZE_DESC, STOREFILE_SIZE, STOREFILE_SIZE_DESC, STOREFILE_SIZE_GROWTH_RATE, STOREFILE_SIZE_GROWTH_RATE_DESC, TOTAL_BYTES_READ, TOTAL_BYTES_READ_DESC, TOTAL_REQUEST_COUNT, TOTAL_REQUEST_COUNT_DESC, TOTAL_ROW_ACTION_REQUEST_COUNT, TOTAL_ROW_ACTION_REQUEST_COUNT_DESC, UPDATES_BLOCKED_DESC, UPDATES_BLOCKED_TIME, WALFILE_COUNT, WALFILE_COUNT_DESC, WALFILE_SIZE, WALFILE_SIZE_DESC, WRITE_REQUEST_COUNT, WRITE_REQUEST_COUNT_DESC, WRITE_REQUEST_RATE_DESC, WRITE_REQUEST_RATE_PER_SECOND, ZEROCOPY_BYTES_READ, ZEROCOPY_BYTES_READ_DESC, ZOOKEEPER_QUORUM_DESC, ZOOKEEPER_QUORUM_NAME

Constructor Summary

Constructors

Constructor	Description
MetricsRegionServerSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext, MetricsRegionServerWrapper rsWrap)
MetricsRegionServerSourceImpl(MetricsRegionServerWrapper rsWrap)

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.metrics2.MetricsRecordBuilder	addGaugesToMetricsRecordBuilder(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb)
void	getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector, boolean all)	Yes this is a get function that doesn't return anything.
void	incInfoThresholdExceeded(int count)	Increment the INFO level threshold exceeded count
void	incrScannerLeaseExpired()
void	incrSlowAppend()	Increment the number of slow Appends that have happened.
void	incrSlowDelete()	Increment the number of slow Deletes that have happened.
void	incrSlowGet()	Increment the number of slow Gets that have happened.
void	incrSlowIncrement()	Increment the number of slow Increments that have happened.
void	incrSlowPut()	Increment the number of slow Puts that have happened.
void	incrSplitRequest()	Increment number of a requested splits
void	incrSplitSuccess()	Increment number of successful splits
void	incWarnThresholdExceeded(int count)	Increment the WARN level threshold exceeded count
void	updateAppend(long t, long blockBytesScanned)	Update the Append time histogram.
void	updateCheckAndDelete(long t)	Update checkAndDelete histogram
void	updateCheckAndMutate(long time, long blockBytesScanned)	Update checkAndMutate histogram
void	updateCheckAndPut(long t)	Update checkAndPut histogram
void	updateCompactionInputFileCount(boolean isMajor, long c)	Update the compaction input number of files histogram
void	updateCompactionInputSize(boolean isMajor, long bytes)	Update the compaction total input file size histogram
void	updateCompactionOutputFileCount(boolean isMajor, long c)	Update the compaction output number of files histogram
void	updateCompactionOutputSize(boolean isMajor, long bytes)	Update the compaction total output file size
void	updateCompactionTime(boolean isMajor, long t)	Update the compaction time histogram, both major and minor
void	updateDelete(long t)	Update the Delete time histogram
void	updateDeleteBatch(long t)	Update the Delete time histogram if a batch contains a delete op
void	updateFlushMemStoreSize(long bytes)	Update the flush memstore size histogram
void	updateFlushOutputSize(long bytes)	Update the flush output file size histogram
void	updateFlushTime(long t)	Update the flush time histogram
void	updateGet(long t, long blockBytesScanned)	Update the Get time histogram .
void	updateIncrement(long t, long blockBytesScanned)	Update the Increment time histogram.
void	updatePauseTimeWithGc(long t)	Update the pause time histogram where GC activity was detected.
void	updatePauseTimeWithoutGc(long t)	Update the pause time histogram where GC activity was not detected.
void	updatePut(long t)	Update the Put time histogram
void	updatePutBatch(long t)	Update the PutBatch time histogram if a batch contains a Put op
void	updateReplay(long t)	Update the Replay time histogram.
void	updateScan(long time, long responseSize, long blockBytesScanned)	Update the scan metrics.
void	updateSplitTime(long t)	Update the split transaction time histogram

Methods inherited from class org.apache.hadoop.hbase.metrics.BaseSourceImpl

decGauge, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, init, removeMetric, setGauge, updateHistogram

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.metrics.BaseSource

decGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, init, removeMetric, setGauge, updateHistogram

Field Details

rsWrap

final MetricsRegionServerWrapper rsWrap

putHisto

private final MetricHistogram putHisto

putBatchHisto

private final MetricHistogram putBatchHisto

deleteHisto

private final MetricHistogram deleteHisto

deleteBatchHisto

private final MetricHistogram deleteBatchHisto

checkAndDeleteHisto

private final MetricHistogram checkAndDeleteHisto

checkAndPutHisto

private final MetricHistogram checkAndPutHisto

checkAndMutateHisto

private final MetricHistogram checkAndMutateHisto

getHisto

private final MetricHistogram getHisto

incrementHisto

private final MetricHistogram incrementHisto

appendHisto

private final MetricHistogram appendHisto

replayHisto

private final MetricHistogram replayHisto

scanSizeHisto

private final MetricHistogram scanSizeHisto

scanTimeHisto

private final MetricHistogram scanTimeHisto

blockBytesScannedCount

private final MutableFastCounter blockBytesScannedCount

checkAndMutateBlockBytesScanned

private final MetricHistogram checkAndMutateBlockBytesScanned

getBlockBytesScanned

private final MetricHistogram getBlockBytesScanned

incrementBlockBytesScanned

private final MetricHistogram incrementBlockBytesScanned

appendBlockBytesScanned

private final MetricHistogram appendBlockBytesScanned

scanBlockBytesScanned

private final MetricHistogram scanBlockBytesScanned

slowPut

private final MutableFastCounter slowPut

slowDelete

private final MutableFastCounter slowDelete

slowGet

private final MutableFastCounter slowGet

slowIncrement

private final MutableFastCounter slowIncrement

slowAppend

private final MutableFastCounter slowAppend

splitRequest

private final MutableFastCounter splitRequest

splitSuccess

private final MutableFastCounter splitSuccess

splitTimeHisto

private final MetricHistogram splitTimeHisto

flushTimeHisto

private final MetricHistogram flushTimeHisto

flushMemstoreSizeHisto

private final MetricHistogram flushMemstoreSizeHisto

flushOutputSizeHisto

private final MetricHistogram flushOutputSizeHisto

flushedMemstoreBytes

private final MutableFastCounter flushedMemstoreBytes

flushedOutputBytes

private final MutableFastCounter flushedOutputBytes

compactionTimeHisto

private final MetricHistogram compactionTimeHisto

compactionInputFileCountHisto

private final MetricHistogram compactionInputFileCountHisto

compactionInputSizeHisto

private final MetricHistogram compactionInputSizeHisto

compactionOutputFileCountHisto

private final MetricHistogram compactionOutputFileCountHisto

compactionOutputSizeHisto

private final MetricHistogram compactionOutputSizeHisto

compactedInputBytes

private final MutableFastCounter compactedInputBytes

compactedOutputBytes

private final MutableFastCounter compactedOutputBytes

majorCompactionTimeHisto

private final MetricHistogram majorCompactionTimeHisto

majorCompactionInputFileCountHisto

private final MetricHistogram majorCompactionInputFileCountHisto

majorCompactionInputSizeHisto

private final MetricHistogram majorCompactionInputSizeHisto

majorCompactionOutputFileCountHisto

private final MetricHistogram majorCompactionOutputFileCountHisto

majorCompactionOutputSizeHisto

private final MetricHistogram majorCompactionOutputSizeHisto

majorCompactedInputBytes

private final MutableFastCounter majorCompactedInputBytes

majorCompactedOutputBytes

private final MutableFastCounter majorCompactedOutputBytes

infoPauseThresholdExceeded

private final MutableFastCounter infoPauseThresholdExceeded

warnPauseThresholdExceeded

private final MutableFastCounter warnPauseThresholdExceeded

pausesWithGc

private final MetricHistogram pausesWithGc

pausesWithoutGc

private final MetricHistogram pausesWithoutGc

scannerLeaseExpiredCount

private final MutableFastCounter scannerLeaseExpiredCount

Constructor Details

MetricsRegionServerSourceImpl

public MetricsRegionServerSourceImpl(MetricsRegionServerWrapper rsWrap)

MetricsRegionServerSourceImpl

public MetricsRegionServerSourceImpl(String metricsName,
 String metricsDescription,
 String metricsContext,
 String metricsJmxContext,
 MetricsRegionServerWrapper rsWrap)

Method Details

updatePut

public void updatePut(long t)

Description copied from interface: MetricsRegionServerSource

Update the Put time histogram

Specified by:

updatePut in interface MetricsRegionServerSource

Parameters:

t - time it took

updateDelete

public void updateDelete(long t)

Description copied from interface: MetricsRegionServerSource

Update the Delete time histogram

Specified by:

updateDelete in interface MetricsRegionServerSource

Parameters:

t - time it took

updateGet

public void updateGet(long t,
 long blockBytesScanned)

Description copied from interface: MetricsRegionServerSource

Update the Get time histogram .

Specified by:

updateGet in interface MetricsRegionServerSource

Parameters:

t - time it took

blockBytesScanned - how many block bytes were scanned for the request

updateIncrement

public void updateIncrement(long t,
 long blockBytesScanned)

Description copied from interface: MetricsRegionServerSource

Update the Increment time histogram.

Specified by:

updateIncrement in interface MetricsRegionServerSource

Parameters:

t - time it took

blockBytesScanned - how many block bytes were scanned fetching the current value to increment

updateAppend

public void updateAppend(long t,
 long blockBytesScanned)

Description copied from interface: MetricsRegionServerSource

Update the Append time histogram.

Specified by:

updateAppend in interface MetricsRegionServerSource

Parameters:

t - time it took

blockBytesScanned - how many block bytes were scanned fetching the current value to append

updateReplay

public void updateReplay(long t)

Description copied from interface: MetricsRegionServerSource

Update the Replay time histogram.

Specified by:

updateReplay in interface MetricsRegionServerSource

Parameters:

t - time it took

updateScan

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

Description copied from interface: MetricsRegionServerSource

Update the scan metrics.

Specified by:

updateScan in interface MetricsRegionServerSource

Parameters:

time - response time of scan

responseSize - size of the scan resposne

blockBytesScanned - size of block bytes scanned to retrieve the response

incrSlowPut

public void incrSlowPut()

Description copied from interface: MetricsRegionServerSource

Increment the number of slow Puts that have happened.

Specified by:

incrSlowPut in interface MetricsRegionServerSource

incrSlowDelete

public void incrSlowDelete()

Description copied from interface: MetricsRegionServerSource

Increment the number of slow Deletes that have happened.

Specified by:

incrSlowDelete in interface MetricsRegionServerSource

incrSlowGet

public void incrSlowGet()

Description copied from interface: MetricsRegionServerSource

Increment the number of slow Gets that have happened.

Specified by:

incrSlowGet in interface MetricsRegionServerSource

incrSlowIncrement

public void incrSlowIncrement()

Description copied from interface: MetricsRegionServerSource

Increment the number of slow Increments that have happened.

Specified by:

incrSlowIncrement in interface MetricsRegionServerSource

incrSlowAppend

public void incrSlowAppend()

Description copied from interface: MetricsRegionServerSource

Increment the number of slow Appends that have happened.

Specified by:

incrSlowAppend in interface MetricsRegionServerSource

incrSplitRequest

public void incrSplitRequest()

Description copied from interface: MetricsRegionServerSource

Increment number of a requested splits

Specified by:

incrSplitRequest in interface MetricsRegionServerSource

incrSplitSuccess

public void incrSplitSuccess()

Description copied from interface: MetricsRegionServerSource

Increment number of successful splits

Specified by:

incrSplitSuccess in interface MetricsRegionServerSource

updateSplitTime

public void updateSplitTime(long t)

Description copied from interface: MetricsRegionServerSource

Update the split transaction time histogram

Specified by:

updateSplitTime in interface MetricsRegionServerSource

Parameters:

t - time it took, in milliseconds

updateFlushTime

public void updateFlushTime(long t)

Description copied from interface: MetricsRegionServerSource

Update the flush time histogram

Specified by:

updateFlushTime in interface MetricsRegionServerSource

Parameters:

t - time it took, in milliseconds

updateFlushMemStoreSize

public void updateFlushMemStoreSize(long bytes)

Description copied from interface: MetricsRegionServerSource

Update the flush memstore size histogram

Specified by:

updateFlushMemStoreSize in interface MetricsRegionServerSource

Parameters:

bytes - the number of bytes in the memstore

updateFlushOutputSize

public void updateFlushOutputSize(long bytes)

Description copied from interface: MetricsRegionServerSource

Update the flush output file size histogram

Specified by:

updateFlushOutputSize in interface MetricsRegionServerSource

Parameters:

bytes - the number of bytes in the output file

updateCompactionTime

public void updateCompactionTime(boolean isMajor,
 long t)

Description copied from interface: MetricsRegionServerSource

Update the compaction time histogram, both major and minor

Specified by:

updateCompactionTime in interface MetricsRegionServerSource

Parameters:

isMajor - whether compaction is a major compaction

t - time it took, in milliseconds

updateCompactionInputFileCount

public void updateCompactionInputFileCount(boolean isMajor,
 long c)

Description copied from interface: MetricsRegionServerSource

Update the compaction input number of files histogram

Specified by:

updateCompactionInputFileCount in interface MetricsRegionServerSource

Parameters:

isMajor - whether compaction is a major compaction

c - number of files

updateCompactionInputSize

public void updateCompactionInputSize(boolean isMajor,
 long bytes)

Description copied from interface: MetricsRegionServerSource

Update the compaction total input file size histogram

Specified by:

updateCompactionInputSize in interface MetricsRegionServerSource

Parameters:

isMajor - whether compaction is a major compaction

bytes - the number of bytes of the compaction input file

updateCompactionOutputFileCount

public void updateCompactionOutputFileCount(boolean isMajor,
 long c)

Description copied from interface: MetricsRegionServerSource

Update the compaction output number of files histogram

Specified by:

updateCompactionOutputFileCount in interface MetricsRegionServerSource

Parameters:

isMajor - whether compaction is a major compaction

c - number of files

updateCompactionOutputSize

public void updateCompactionOutputSize(boolean isMajor,
 long bytes)

Description copied from interface: MetricsRegionServerSource

Update the compaction total output file size

Specified by:

updateCompactionOutputSize in interface MetricsRegionServerSource

Parameters:

isMajor - whether compaction is a major compaction

bytes - the number of bytes of the compaction input file

incrScannerLeaseExpired

public void incrScannerLeaseExpired()

Specified by:

incrScannerLeaseExpired in interface MetricsRegionServerSource

getMetrics

public void getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector,
 boolean all)

Yes this is a get function that doesn't return anything. Thanks Hadoop for breaking all expectations of java programmers. Instead of returning anything Hadoop metrics expects getMetrics to push the metrics into the collector.

Specified by:

getMetrics in interface org.apache.hadoop.metrics2.MetricsSource

Overrides:

getMetrics in class BaseSourceImpl

Parameters:

metricsCollector - Collector to accept metrics

all - push all or only changed?

addGaugesToMetricsRecordBuilder

private org.apache.hadoop.metrics2.MetricsRecordBuilder addGaugesToMetricsRecordBuilder(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb)

incInfoThresholdExceeded

public void incInfoThresholdExceeded(int count)

Description copied from interface: JvmPauseMonitorSource

Increment the INFO level threshold exceeded count

Specified by:

incInfoThresholdExceeded in interface JvmPauseMonitorSource

Parameters:

count - the count

incWarnThresholdExceeded

public void incWarnThresholdExceeded(int count)

Description copied from interface: JvmPauseMonitorSource

Increment the WARN level threshold exceeded count

Specified by:

incWarnThresholdExceeded in interface JvmPauseMonitorSource

Parameters:

count - the count

updatePauseTimeWithGc

public void updatePauseTimeWithGc(long t)

Description copied from interface: JvmPauseMonitorSource

Update the pause time histogram where GC activity was detected.

Specified by:

updatePauseTimeWithGc in interface JvmPauseMonitorSource

Parameters:

t - time it took

updatePauseTimeWithoutGc

public void updatePauseTimeWithoutGc(long t)

Description copied from interface: JvmPauseMonitorSource

Update the pause time histogram where GC activity was not detected.

Specified by:

updatePauseTimeWithoutGc in interface JvmPauseMonitorSource

Parameters:

t - time it took

updateDeleteBatch

public void updateDeleteBatch(long t)

Description copied from interface: MetricsRegionServerSource

Update the Delete time histogram if a batch contains a delete op

Specified by:

updateDeleteBatch in interface MetricsRegionServerSource

Parameters:

t - time it took

updateCheckAndDelete

public void updateCheckAndDelete(long t)

Description copied from interface: MetricsRegionServerSource

Update checkAndDelete histogram

Specified by:

updateCheckAndDelete in interface MetricsRegionServerSource

Parameters:

t - time it took

updateCheckAndPut

public void updateCheckAndPut(long t)

Description copied from interface: MetricsRegionServerSource

Update checkAndPut histogram

Specified by:

updateCheckAndPut in interface MetricsRegionServerSource

Parameters:

t - time it took

updateCheckAndMutate

public void updateCheckAndMutate(long time,
 long blockBytesScanned)

Description copied from interface: MetricsRegionServerSource

Update checkAndMutate histogram

Specified by:

updateCheckAndMutate in interface MetricsRegionServerSource

Parameters:

time - time it took

blockBytesScanned - how many block bytes were scanned for the check portion of the request

updatePutBatch

public void updatePutBatch(long t)

Description copied from interface: MetricsRegionServerSource

Update the PutBatch time histogram if a batch contains a Put op

Specified by:

updatePutBatch in interface MetricsRegionServerSource

Parameters:

t - time it took