@InterfaceAudience.Private public class MetricsRegionServerSourceImpl extends BaseSourceImpl implements MetricsRegionServerSource
metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registry
ACTIVE_SCANNERS, ACTIVE_SCANNERS_DESC, 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_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_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, 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_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_IN_CUR_THREAD, HEDGED_READ_IN_CUR_THREAD_DESC, HEDGED_READ_WINS, HEDGED_READ_WINS_DESC, HEDGED_READS, HEDGED_READS_DESC, 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_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_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, 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
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 |
---|---|
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)
Update the Append time histogram.
|
void |
updateCheckAndDelete(long t)
Update checkAndDelete histogram
|
void |
updateCheckAndMutate(long t)
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)
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 n
|
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
final MetricsRegionServerWrapper rsWrap
private final MetricHistogram putHisto
private final MetricHistogram putBatchHisto
private final MetricHistogram deleteHisto
private final MetricHistogram deleteBatchHisto
private final MetricHistogram checkAndDeleteHisto
private final MetricHistogram checkAndPutHisto
private final MetricHistogram checkAndMutateHisto
private final MetricHistogram getHisto
private final MetricHistogram incrementHisto
private final MetricHistogram appendHisto
private final MetricHistogram replayHisto
private final MetricHistogram scanSizeHisto
private final MetricHistogram scanTimeHisto
private final MutableFastCounter slowPut
private final MutableFastCounter slowDelete
private final MutableFastCounter slowGet
private final MutableFastCounter slowIncrement
private final MutableFastCounter slowAppend
private final MutableFastCounter splitRequest
private final MutableFastCounter splitSuccess
private final MetricHistogram splitTimeHisto
private final MetricHistogram flushTimeHisto
private final MetricHistogram flushMemstoreSizeHisto
private final MetricHistogram flushOutputSizeHisto
private final MutableFastCounter flushedMemstoreBytes
private final MutableFastCounter flushedOutputBytes
private final MetricHistogram compactionTimeHisto
private final MetricHistogram compactionInputFileCountHisto
private final MetricHistogram compactionInputSizeHisto
private final MetricHistogram compactionOutputFileCountHisto
private final MetricHistogram compactionOutputSizeHisto
private final MutableFastCounter compactedInputBytes
private final MutableFastCounter compactedOutputBytes
private final MetricHistogram majorCompactionTimeHisto
private final MetricHistogram majorCompactionInputFileCountHisto
private final MetricHistogram majorCompactionInputSizeHisto
private final MetricHistogram majorCompactionOutputFileCountHisto
private final MetricHistogram majorCompactionOutputSizeHisto
private final MutableFastCounter majorCompactedInputBytes
private final MutableFastCounter majorCompactedOutputBytes
private final MutableFastCounter infoPauseThresholdExceeded
private final MutableFastCounter warnPauseThresholdExceeded
private final MetricHistogram pausesWithGc
private final MetricHistogram pausesWithoutGc
private final MutableFastCounter scannerLeaseExpiredCount
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 incrScannerLeaseExpired()
incrScannerLeaseExpired
in interface MetricsRegionServerSource
public 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?private org.apache.hadoop.metrics2.MetricsRecordBuilder addGaugesToMetricsRecordBuilder(org.apache.hadoop.metrics2.MetricsRecordBuilder mrb)
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 updateCheckAndMutate(long t)
MetricsRegionServerSource
updateCheckAndMutate
in interface MetricsRegionServerSource
t
- time it tookpublic void updatePutBatch(long t)
MetricsRegionServerSource
updatePutBatch
in interface MetricsRegionServerSource
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.