org.apache.hadoop.hbase.regionserver

Class MetricsHeapMemoryManagerSourceImpl

java.lang.Object

org.apache.hadoop.hbase.metrics.BaseSourceImpl

org.apache.hadoop.hbase.regionserver.MetricsHeapMemoryManagerSourceImpl

All Implemented Interfaces:

BaseSource, MetricsHeapMemoryManagerSource, org.apache.hadoop.metrics2.MetricsSource

@InterfaceAudience.Private
public class MetricsHeapMemoryManagerSourceImpl
extends BaseSourceImpl
implements MetricsHeapMemoryManagerSource

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

Field Summary

Fields

Modifier and Type	Field and Description
private MutableFastCounter	aboveHeapOccupancyLowWatermarkCounter
private org.apache.hadoop.metrics2.lib.MutableGaugeLong	blockCacheSizeGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong	blockedFlushGauge
private MetricHistogram	blockedFlushHistogram
private MetricHistogram	decBlockCacheSizeHistogram
private MetricHistogram	decMemStoreSizeHistogram
private MutableFastCounter	doNothingCounter
private MetricHistogram	incBlockCacheSizeHistogram
private MetricHistogram	incMemStoreSizeHistogram
private org.apache.hadoop.metrics2.lib.MutableGaugeLong	memStoreSizeGauge
private org.apache.hadoop.metrics2.lib.MutableGaugeLong	unblockedFlushGauge
private MetricHistogram	unblockedFlushHistogram

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.regionserver.MetricsHeapMemoryManagerSource

ABOVE_HEAP_LOW_WATERMARK_COUNTER_DESC, ABOVE_HEAP_LOW_WATERMARK_COUNTER_NAME, BLOCKCACHE_SIZE_GAUGE_DESC, BLOCKCACHE_SIZE_GAUGE_NAME, BLOCKED_FLUSH_DESC, BLOCKED_FLUSH_GAUGE_DESC, BLOCKED_FLUSH_GAUGE_NAME, BLOCKED_FLUSH_NAME, DEC_BLOCKCACHE_TUNING_DESC, DEC_BLOCKCACHE_TUNING_NAME, DEC_MEMSTORE_TUNING_DESC, DEC_MEMSTORE_TUNING_NAME, DO_NOTHING_COUNTER_DESC, DO_NOTHING_COUNTER_NAME, INC_BLOCKCACHE_TUNING_DESC, INC_BLOCKCACHE_TUNING_NAME, INC_MEMSTORE_TUNING_DESC, INC_MEMSTORE_TUNING_NAME, MEMSTORE_SIZE_GAUGE_DESC, MEMSTORE_SIZE_GAUGE_NAME, METRICS_CONTEXT, METRICS_DESCRIPTION, METRICS_JMX_CONTEXT, METRICS_NAME, UNBLOCKED_FLUSH_DESC, UNBLOCKED_FLUSH_GAUGE_DESC, UNBLOCKED_FLUSH_GAUGE_NAME, UNBLOCKED_FLUSH_NAME

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

HBASE_METRICS_SYSTEM_NAME

Constructor Summary

Constructors

Constructor and Description
MetricsHeapMemoryManagerSourceImpl()
MetricsHeapMemoryManagerSourceImpl(String metricsName, String metricsDescription, String metricsContext, String metricsJmxContext)

Method Summary

Modifier and Type	Method and Description
void	increaseAboveHeapOccupancyLowWatermarkCounter() Increase the counter for heap occupancy percent above low watermark
void	increaseTunerDoNothingCounter() Increase the counter for tuner neither expanding memstore global size limit nor expanding blockcache max size.
void	setCurBlockCacheSizeGauge(long blockcacheSize) Set the current blockcache size used gauge
void	setCurMemStoreSizeGauge(long memstoreSize) Set the current global memstore size used gauge
void	updateBlockCacheDeltaSizeHistogram(int blockCacheDeltaSize) Update the increase/decrease blockcache size histogram
void	updateBlockedFlushCount(long blockedFlushCount) Update/Set the blocked flush count histogram/gauge
void	updateMemStoreDeltaSizeHistogram(int memStoreDeltaSize) Update the increase/decrease memstore size histogram
void	updateUnblockedFlushCount(long unblockedFlushCount) Update/Set the unblocked flush count histogram/gauge

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

decGauge, getMetrics, 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 Detail

blockedFlushHistogram

private final MetricHistogram blockedFlushHistogram

unblockedFlushHistogram

private final MetricHistogram unblockedFlushHistogram

incMemStoreSizeHistogram

private final MetricHistogram incMemStoreSizeHistogram

decMemStoreSizeHistogram

private final MetricHistogram decMemStoreSizeHistogram

incBlockCacheSizeHistogram

private final MetricHistogram incBlockCacheSizeHistogram

decBlockCacheSizeHistogram

private final MetricHistogram decBlockCacheSizeHistogram

blockedFlushGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong blockedFlushGauge

unblockedFlushGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong unblockedFlushGauge

memStoreSizeGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong memStoreSizeGauge

blockCacheSizeGauge

private final org.apache.hadoop.metrics2.lib.MutableGaugeLong blockCacheSizeGauge

doNothingCounter

private final MutableFastCounter doNothingCounter

aboveHeapOccupancyLowWatermarkCounter

private final MutableFastCounter aboveHeapOccupancyLowWatermarkCounter

Constructor Detail

MetricsHeapMemoryManagerSourceImpl

public MetricsHeapMemoryManagerSourceImpl()

MetricsHeapMemoryManagerSourceImpl

public MetricsHeapMemoryManagerSourceImpl(String metricsName,
                                          String metricsDescription,
                                          String metricsContext,
                                          String metricsJmxContext)

Method Detail

updateBlockedFlushCount

public void updateBlockedFlushCount(long blockedFlushCount)

Description copied from interface: MetricsHeapMemoryManagerSource

Update/Set the blocked flush count histogram/gauge

Specified by:

updateBlockedFlushCount in interface MetricsHeapMemoryManagerSource

Parameters:

blockedFlushCount - the number of blocked flush since last tuning.

updateUnblockedFlushCount

public void updateUnblockedFlushCount(long unblockedFlushCount)

Description copied from interface: MetricsHeapMemoryManagerSource

Update/Set the unblocked flush count histogram/gauge

Specified by:

updateUnblockedFlushCount in interface MetricsHeapMemoryManagerSource

Parameters:

unblockedFlushCount - the number of unblocked flush since last tuning.

setCurBlockCacheSizeGauge

public void setCurBlockCacheSizeGauge(long blockcacheSize)

Description copied from interface: MetricsHeapMemoryManagerSource

Set the current blockcache size used gauge

Specified by:

setCurBlockCacheSizeGauge in interface MetricsHeapMemoryManagerSource

Parameters:

blockcacheSize - the current memory usage in blockcache, in bytes.

setCurMemStoreSizeGauge

public void setCurMemStoreSizeGauge(long memstoreSize)

Description copied from interface: MetricsHeapMemoryManagerSource

Set the current global memstore size used gauge

Specified by:

setCurMemStoreSizeGauge in interface MetricsHeapMemoryManagerSource

Parameters:

memstoreSize - the current memory usage in memstore, in bytes.

updateMemStoreDeltaSizeHistogram

public void updateMemStoreDeltaSizeHistogram(int memStoreDeltaSize)

Description copied from interface: MetricsHeapMemoryManagerSource

Update the increase/decrease memstore size histogram

Specified by:

updateMemStoreDeltaSizeHistogram in interface MetricsHeapMemoryManagerSource

Parameters:

memStoreDeltaSize - the tuning result of memstore.

updateBlockCacheDeltaSizeHistogram

public void updateBlockCacheDeltaSizeHistogram(int blockCacheDeltaSize)

Description copied from interface: MetricsHeapMemoryManagerSource

Update the increase/decrease blockcache size histogram

Specified by:

updateBlockCacheDeltaSizeHistogram in interface MetricsHeapMemoryManagerSource

Parameters:

blockCacheDeltaSize - the tuning result of blockcache.

increaseTunerDoNothingCounter

public void increaseTunerDoNothingCounter()

Description copied from interface: MetricsHeapMemoryManagerSource

Increase the counter for tuner neither expanding memstore global size limit nor expanding blockcache max size.

Specified by:

increaseTunerDoNothingCounter in interface MetricsHeapMemoryManagerSource

increaseAboveHeapOccupancyLowWatermarkCounter

public void increaseAboveHeapOccupancyLowWatermarkCounter()

Description copied from interface: MetricsHeapMemoryManagerSource

Increase the counter for heap occupancy percent above low watermark

Specified by:

increaseAboveHeapOccupancyLowWatermarkCounter in interface MetricsHeapMemoryManagerSource