Package 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

@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	Description
private final MutableFastCounter	aboveHeapOccupancyLowWatermarkCounter
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong	blockCacheSizeGauge
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong	blockedFlushGauge
private final MetricHistogram	blockedFlushHistogram
private final MetricHistogram	decBlockCacheSizeHistogram
private final MetricHistogram	decMemStoreSizeHistogram
private final MutableFastCounter	doNothingCounter
private final MetricHistogram	incBlockCacheSizeHistogram
private final MetricHistogram	incMemStoreSizeHistogram
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong	memStoreOffHeapSizeGauge
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong	memStoreOnHeapSizeGauge
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong	memStoreSizeGauge
private final org.apache.hadoop.metrics2.lib.MutableGaugeLong	unblockedFlushGauge
private final 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.metrics.BaseSource

HBASE_METRICS_SYSTEM_NAME

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_OFFHEAP_SIZE_GAUGE_DESC, MEMSTORE_OFFHEAP_SIZE_GAUGE_NAME, MEMSTORE_ONHEAP_SIZE_GAUGE_DESC, MEMSTORE_ONHEAP_SIZE_GAUGE_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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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	setCurMemStoreOffHeapSizeGauge(long memstoreOffHeapSize)	Set the current global memstore off-heap size used gauge
void	setCurMemStoreOnHeapSizeGauge(long memstoreOnHeapSize)	Set the current global memstore on-heap 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 Details

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

memStoreOnHeapSizeGauge

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

memStoreOffHeapSizeGauge

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

blockCacheSizeGauge

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

doNothingCounter

private final MutableFastCounter doNothingCounter

aboveHeapOccupancyLowWatermarkCounter

private final MutableFastCounter aboveHeapOccupancyLowWatermarkCounter

Constructor Details

MetricsHeapMemoryManagerSourceImpl

public MetricsHeapMemoryManagerSourceImpl()

MetricsHeapMemoryManagerSourceImpl

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

Method Details

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.

setCurMemStoreOnHeapSizeGauge

public void setCurMemStoreOnHeapSizeGauge(long memstoreOnHeapSize)

Description copied from interface: MetricsHeapMemoryManagerSource

Set the current global memstore on-heap size used gauge

Specified by:

setCurMemStoreOnHeapSizeGauge in interface MetricsHeapMemoryManagerSource

Parameters:

memstoreOnHeapSize - the current memory usage in memstore on-heap, in bytes.

setCurMemStoreOffHeapSizeGauge

public void setCurMemStoreOffHeapSizeGauge(long memstoreOffHeapSize)

Description copied from interface: MetricsHeapMemoryManagerSource

Set the current global memstore off-heap size used gauge

Specified by:

setCurMemStoreOffHeapSizeGauge in interface MetricsHeapMemoryManagerSource

Parameters:

memstoreOffHeapSize - the current memory usage in memstore off-heap, 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