@InterfaceAudience.Private public class MetricsRegionServerSourceImpl extends BaseSourceImpl implements MetricsRegionServerSource
metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registry
APPEND_KEY, AVERAGE_REGION_SIZE, AVERAGE_REGION_SIZE_DESC, AVG_STORE_FILE_AGE, AVG_STORE_FILE_AGE_DESC, BLOCK_CACHE_BLOOM_CHUNK_HIT_COUNT, BLOCK_CACHE_BLOOM_CHUNK_MISS_COUNT, BLOCK_CACHE_COUNT, BLOCK_CACHE_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_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_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_COUNT_DESC, BLOCK_COUNT_PRIMARY_MISS_COUNT_DESC, BLOCKED_REQUESTS_COUNT, BLOCKED_REQUESTS_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_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, 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_KEY, GET_SIZE_KEY, HEDGED_READ_WINS, HEDGED_READ_WINS_DESC, HEDGED_READS, HEDGED_READS_DESC, INCREMENT_KEY, 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, 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, LARGE_COMPACTION_QUEUE_LENGTH, LARGE_COMPACTION_QUEUE_LENGTH_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_STORE_FILE_AGE, MAX_STORE_FILE_AGE_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, REGION_COUNT, REGION_COUNT_DESC, REPLAY_KEY, 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_KEY, SCAN_SIZE_KEY, SCAN_TIME_KEY, SERVER_NAME_DESC, SERVER_NAME_NAME, 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, STOREFILE_COUNT, STOREFILE_COUNT_DESC, STOREFILE_INDEX_SIZE, STOREFILE_INDEX_SIZE_DESC, STOREFILE_SIZE, STOREFILE_SIZE_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, ZOOKEEPER_QUORUM_DESC, ZOOKEEPER_QUORUM_NAME
HBASE_METRICS_SYSTEM_NAME
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
Constructor and Description |
---|
MetricsRegionServerSourceImpl(MetricsRegionServerWrapper rsWrap) |
MetricsRegionServerSourceImpl(String metricsName,
String metricsDescription,
String metricsContext,
String metricsJmxContext,
MetricsRegionServerWrapper rsWrap) |
Modifier and Type | Method and Description |
---|---|
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 |
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)
Update the Append time histogram.
|
void |
updateCheckAndDelete(long t)
Update checkAndDelete 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)
Update the Get time histogram .
|
void |
updateIncrement(long t)
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 |
updateScanSize(long scanSize)
Update the scan size.
|
void |
updateScanTime(long t)
Update the scan time.
|
void |
updateSplitTime(long t)
Update the split transaction time histogram
|
decGauge, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, init, removeMetric, setGauge, updateHistogram
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, init, removeMetric, setGauge, updateHistogram
public MetricsRegionServerSourceImpl(MetricsRegionServerWrapper rsWrap)
public MetricsRegionServerSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext, MetricsRegionServerWrapper rsWrap)
public void updatePut(long t)
MetricsRegionServerSource
updatePut
in interface MetricsRegionServerSource
t
- time it tookpublic void updateDelete(long t)
MetricsRegionServerSource
updateDelete
in interface MetricsRegionServerSource
t
- time it tookpublic void updateGet(long t)
MetricsRegionServerSource
updateGet
in interface MetricsRegionServerSource
t
- time it tookpublic void updateIncrement(long t)
MetricsRegionServerSource
updateIncrement
in interface MetricsRegionServerSource
t
- time it tookpublic void updateAppend(long t)
MetricsRegionServerSource
updateAppend
in interface MetricsRegionServerSource
t
- time it tookpublic void updateReplay(long t)
MetricsRegionServerSource
updateReplay
in interface MetricsRegionServerSource
t
- time it tookpublic void updateScanSize(long scanSize)
MetricsRegionServerSource
updateScanSize
in interface MetricsRegionServerSource
scanSize
- size of the scanpublic void updateScanTime(long t)
MetricsRegionServerSource
updateScanTime
in interface MetricsRegionServerSource
public void incrSlowPut()
MetricsRegionServerSource
incrSlowPut
in interface MetricsRegionServerSource
public void incrSlowDelete()
MetricsRegionServerSource
incrSlowDelete
in interface MetricsRegionServerSource
public void incrSlowGet()
MetricsRegionServerSource
incrSlowGet
in interface MetricsRegionServerSource
public void incrSlowIncrement()
MetricsRegionServerSource
incrSlowIncrement
in interface MetricsRegionServerSource
public void incrSlowAppend()
MetricsRegionServerSource
incrSlowAppend
in interface MetricsRegionServerSource
public void incrSplitRequest()
MetricsRegionServerSource
incrSplitRequest
in interface MetricsRegionServerSource
public void incrSplitSuccess()
MetricsRegionServerSource
incrSplitSuccess
in interface MetricsRegionServerSource
public void updateSplitTime(long t)
MetricsRegionServerSource
updateSplitTime
in interface MetricsRegionServerSource
t
- time it took, in millisecondspublic void updateFlushTime(long t)
MetricsRegionServerSource
updateFlushTime
in interface MetricsRegionServerSource
t
- time it took, in millisecondspublic void updateFlushMemStoreSize(long bytes)
MetricsRegionServerSource
updateFlushMemStoreSize
in interface MetricsRegionServerSource
bytes
- the number of bytes in the memstorepublic void updateFlushOutputSize(long bytes)
MetricsRegionServerSource
updateFlushOutputSize
in interface MetricsRegionServerSource
bytes
- the number of bytes in the output filepublic void updateCompactionTime(boolean isMajor, long t)
MetricsRegionServerSource
updateCompactionTime
in interface MetricsRegionServerSource
isMajor
- whether compaction is a major compactiont
- time it took, in millisecondspublic void updateCompactionInputFileCount(boolean isMajor, long c)
MetricsRegionServerSource
updateCompactionInputFileCount
in interface MetricsRegionServerSource
isMajor
- whether compaction is a major compactionc
- number of filespublic void updateCompactionInputSize(boolean isMajor, long bytes)
MetricsRegionServerSource
updateCompactionInputSize
in interface MetricsRegionServerSource
isMajor
- whether compaction is a major compactionbytes
- the number of bytes of the compaction input filepublic void updateCompactionOutputFileCount(boolean isMajor, long c)
MetricsRegionServerSource
updateCompactionOutputFileCount
in interface MetricsRegionServerSource
isMajor
- whether compaction is a major compactionc
- number of filespublic void updateCompactionOutputSize(boolean isMajor, long bytes)
MetricsRegionServerSource
updateCompactionOutputSize
in interface MetricsRegionServerSource
isMajor
- whether compaction is a major compactionbytes
- the number of bytes of the compaction input filepublic void getMetrics(org.apache.hadoop.metrics2.MetricsCollector metricsCollector, boolean all)
getMetrics
in interface org.apache.hadoop.metrics2.MetricsSource
getMetrics
in class BaseSourceImpl
metricsCollector
- Collector to accept metricsall
- push all or only changed?public void incInfoThresholdExceeded(int count)
JvmPauseMonitorSource
incInfoThresholdExceeded
in interface JvmPauseMonitorSource
count
- the countpublic void incWarnThresholdExceeded(int count)
JvmPauseMonitorSource
incWarnThresholdExceeded
in interface JvmPauseMonitorSource
count
- the countpublic void updatePauseTimeWithGc(long t)
JvmPauseMonitorSource
updatePauseTimeWithGc
in interface JvmPauseMonitorSource
t
- time it tookpublic void updatePauseTimeWithoutGc(long t)
JvmPauseMonitorSource
updatePauseTimeWithoutGc
in interface JvmPauseMonitorSource
t
- time it tookpublic void updateDeleteBatch(long t)
MetricsRegionServerSource
updateDeleteBatch
in interface MetricsRegionServerSource
t
- time it tookpublic void updateCheckAndDelete(long t)
MetricsRegionServerSource
updateCheckAndDelete
in interface MetricsRegionServerSource
t
- time it tookpublic void updateCheckAndPut(long t)
MetricsRegionServerSource
updateCheckAndPut
in interface MetricsRegionServerSource
t
- time it tookpublic void updatePutBatch(long t)
MetricsRegionServerSource
updatePutBatch
in interface MetricsRegionServerSource
Copyright © 2007–2019 Cloudera. All rights reserved.