@InterfaceAudience.Private public class MetricsRegionServerSourceImpl extends BaseSourceImpl implements MetricsRegionServerSource
Modifier and Type | Field and Description |
---|---|
private MetricHistogram |
appendHisto |
private MetricHistogram |
deleteHisto |
private MetricHistogram |
flushTimeHisto |
private MetricHistogram |
getHisto |
private MetricHistogram |
incrementHisto |
private MetricHistogram |
putHisto |
private MetricHistogram |
replayHisto |
(package private) MetricsRegionServerWrapper |
rsWrap |
private MetricHistogram |
scanNextHisto |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
slowAppend |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
slowDelete |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
slowGet |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
slowIncrement |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
slowPut |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
splitRequest |
private org.apache.hadoop.metrics2.lib.MutableCounterLong |
splitSuccess |
private MetricHistogram |
splitTimeHisto |
metricsContext, metricsDescription, metricsJmxContext, metricsName, metricsRegistry
APPEND_KEY, BLOCK_CACHE_COUNT, BLOCK_CACHE_COUNT_DESC, 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_FREE_DESC, BLOCK_CACHE_FREE_SIZE, BLOCK_CACHE_HIT_COUNT, BLOCK_CACHE_HIT_COUNT_DESC, BLOCK_CACHE_HIT_PERCENT, BLOCK_CACHE_HIT_PERCENT_DESC, 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_SIZE, BLOCK_CACHE_SIZE_DESC, BLOCK_COUNT_MISS_COUNT_DESC, BLOCK_COUNT_PRIMARY_MISS_COUNT_DESC, BLOCKED_REQUESTS_COUNT, BLOCKED_REQUESTS_COUNT_DESC, 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, COMPACTION_QUEUE_LENGTH, COMPACTION_QUEUE_LENGTH_DESC, DATA_SIZE_WITHOUT_WAL, DATA_SIZE_WITHOUT_WAL_DESC, DELETE_KEY, FLUSH_KEY, FLUSH_QUEUE_LENGTH, FLUSH_QUEUE_LENGTH_DESC, FLUSHED_CELLS, FLUSHED_CELLS_DESC, FLUSHED_CELLS_SIZE, FLUSHED_CELLS_SIZE_DESC, GET_KEY, INCREMENT_KEY, LARGE_COMPACTION_QUEUE_LENGTH, MAJOR_COMPACTED_CELLS, MAJOR_COMPACTED_CELLS_DESC, MAJOR_COMPACTED_CELLS_SIZE, MAJOR_COMPACTED_CELLS_SIZE_DESC, MEMSTORE_SIZE, MEMSTORE_SIZE_DESC, METRICS_CONTEXT, METRICS_DESCRIPTION, METRICS_JMX_CONTEXT, METRICS_NAME, MUTATE_KEY, 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, READ_REQUEST_COUNT, READ_REQUEST_COUNT_DESC, REGION_COUNT, REGION_COUNT_DESC, REPLAY_KEY, RS_START_TIME_DESC, RS_START_TIME_NAME, SCAN_NEXT_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_MUTATE_DESC, SLOW_MUTATE_KEY, SMALL_COMPACTION_QUEUE_LENGTH, 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, 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
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 |
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 |
updateAppend(long t)
Update the Append time histogram.
|
void |
updateDelete(long t)
Update the Delete time 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 |
updatePut(long t)
Update the Put time histogram
|
void |
updateReplay(long t)
Update the Replay time histogram.
|
void |
updateScannerNext(long scanSize)
Update the scan size.
|
void |
updateSplitTime(long t)
Update the split transaction time histogram
|
decGauge, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, getMetricsRegistry, incCounters, incGauge, init, removeMetric, setGauge, updateHistogram, updateQuantile
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
decGauge, getMetricsContext, getMetricsDescription, getMetricsJmxContext, getMetricsName, incCounters, incGauge, init, removeMetric, setGauge, updateHistogram, updateQuantile
final MetricsRegionServerWrapper rsWrap
private final MetricHistogram putHisto
private final MetricHistogram deleteHisto
private final MetricHistogram getHisto
private final MetricHistogram incrementHisto
private final MetricHistogram appendHisto
private final MetricHistogram replayHisto
private final MetricHistogram scanNextHisto
private final org.apache.hadoop.metrics2.lib.MutableCounterLong slowPut
private final org.apache.hadoop.metrics2.lib.MutableCounterLong slowDelete
private final org.apache.hadoop.metrics2.lib.MutableCounterLong slowGet
private final org.apache.hadoop.metrics2.lib.MutableCounterLong slowIncrement
private final org.apache.hadoop.metrics2.lib.MutableCounterLong slowAppend
private final org.apache.hadoop.metrics2.lib.MutableCounterLong splitRequest
private final org.apache.hadoop.metrics2.lib.MutableCounterLong splitSuccess
private final MetricHistogram splitTimeHisto
private final MetricHistogram flushTimeHisto
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 updateScannerNext(long scanSize)
MetricsRegionServerSource
updateScannerNext
in interface MetricsRegionServerSource
scanSize
- size of the scanpublic 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 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?Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.