@InterfaceAudience.Private public class MetricsRegionServerSourceImpl extends BaseSourceImpl implements MetricsRegionServerSource
metricsAdapter, metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry, registryAPPEND_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, 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, 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, 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, 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, READ_REQUEST_RATE_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, WRITE_REQUEST_RATE, WRITE_REQUEST_RATE_DESC, ZOOKEEPER_QUORUM_DESC, ZOOKEEPER_QUORUM_NAMEHBASE_METRICS_SYSTEM_NAMEINFO_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, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, init, removeMetric, setGauge, updateHistogramclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdecGauge, getMetricRegistryInfo, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, init, removeMetric, setGauge, updateHistogrampublic MetricsRegionServerSourceImpl(MetricsRegionServerWrapper rsWrap)
public MetricsRegionServerSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext, MetricsRegionServerWrapper rsWrap)
public void updatePut(long t)
MetricsRegionServerSourceupdatePut in interface MetricsRegionServerSourcet - time it tookpublic void updateDelete(long t)
MetricsRegionServerSourceupdateDelete in interface MetricsRegionServerSourcet - time it tookpublic void updateGet(long t)
MetricsRegionServerSourceupdateGet in interface MetricsRegionServerSourcet - time it tookpublic void updateIncrement(long t)
MetricsRegionServerSourceupdateIncrement in interface MetricsRegionServerSourcet - time it tookpublic void updateAppend(long t)
MetricsRegionServerSourceupdateAppend in interface MetricsRegionServerSourcet - time it tookpublic void updateReplay(long t)
MetricsRegionServerSourceupdateReplay in interface MetricsRegionServerSourcet - time it tookpublic void updateScanSize(long scanSize)
MetricsRegionServerSourceupdateScanSize in interface MetricsRegionServerSourcescanSize - size of the scanpublic void updateScanTime(long t)
MetricsRegionServerSourceupdateScanTime in interface MetricsRegionServerSourcepublic void incrSlowPut()
MetricsRegionServerSourceincrSlowPut in interface MetricsRegionServerSourcepublic void incrSlowDelete()
MetricsRegionServerSourceincrSlowDelete in interface MetricsRegionServerSourcepublic void incrSlowGet()
MetricsRegionServerSourceincrSlowGet in interface MetricsRegionServerSourcepublic void incrSlowIncrement()
MetricsRegionServerSourceincrSlowIncrement in interface MetricsRegionServerSourcepublic void incrSlowAppend()
MetricsRegionServerSourceincrSlowAppend in interface MetricsRegionServerSourcepublic void incrSplitRequest()
MetricsRegionServerSourceincrSplitRequest in interface MetricsRegionServerSourcepublic void incrSplitSuccess()
MetricsRegionServerSourceincrSplitSuccess in interface MetricsRegionServerSourcepublic void updateSplitTime(long t)
MetricsRegionServerSourceupdateSplitTime in interface MetricsRegionServerSourcet - time it took, in millisecondspublic void updateFlushTime(long t)
MetricsRegionServerSourceupdateFlushTime in interface MetricsRegionServerSourcet - time it took, in millisecondspublic void updateFlushMemstoreSize(long bytes)
MetricsRegionServerSourceupdateFlushMemstoreSize in interface MetricsRegionServerSourcebytes - the number of bytes in the memstorepublic void updateFlushOutputSize(long bytes)
MetricsRegionServerSourceupdateFlushOutputSize in interface MetricsRegionServerSourcebytes - the number of bytes in the output filepublic void updateCompactionTime(boolean isMajor,
long t)
MetricsRegionServerSourceupdateCompactionTime in interface MetricsRegionServerSourceisMajor - whether compaction is a major compactiont - time it took, in millisecondspublic void updateCompactionInputFileCount(boolean isMajor,
long c)
MetricsRegionServerSourceupdateCompactionInputFileCount in interface MetricsRegionServerSourceisMajor - whether compaction is a major compactionc - number of filespublic void updateCompactionInputSize(boolean isMajor,
long bytes)
MetricsRegionServerSourceupdateCompactionInputSize in interface MetricsRegionServerSourceisMajor - whether compaction is a major compactionbytes - the number of bytes of the compaction input filepublic void updateCompactionOutputFileCount(boolean isMajor,
long c)
MetricsRegionServerSourceupdateCompactionOutputFileCount in interface MetricsRegionServerSourceisMajor - whether compaction is a major compactionc - number of filespublic void updateCompactionOutputSize(boolean isMajor,
long bytes)
MetricsRegionServerSourceupdateCompactionOutputSize in interface MetricsRegionServerSourceisMajor - 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.MetricsSourcegetMetrics in class BaseSourceImplmetricsCollector - Collector to accept metricsall - push all or only changed?public void incInfoThresholdExceeded(int count)
JvmPauseMonitorSourceincInfoThresholdExceeded in interface JvmPauseMonitorSourcecount - the countpublic void incWarnThresholdExceeded(int count)
JvmPauseMonitorSourceincWarnThresholdExceeded in interface JvmPauseMonitorSourcecount - the countpublic void updatePauseTimeWithGc(long t)
JvmPauseMonitorSourceupdatePauseTimeWithGc in interface JvmPauseMonitorSourcet - time it tookpublic void updatePauseTimeWithoutGc(long t)
JvmPauseMonitorSourceupdatePauseTimeWithoutGc in interface JvmPauseMonitorSourcet - time it tookpublic void updateDeleteBatch(long t)
MetricsRegionServerSourceupdateDeleteBatch in interface MetricsRegionServerSourcet - time it tookpublic void updateCheckAndDelete(long t)
MetricsRegionServerSourceupdateCheckAndDelete in interface MetricsRegionServerSourcet - time it tookpublic void updateCheckAndPut(long t)
MetricsRegionServerSourceupdateCheckAndPut in interface MetricsRegionServerSourcet - time it tookpublic void updatePutBatch(long t)
MetricsRegionServerSourceupdatePutBatch in interface MetricsRegionServerSourceCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.