Package org.apache.hadoop.hbase.regionserver

Class RegionServerAccounting

java.lang.Object

org.apache.hadoop.hbase.regionserver.RegionServerAccounting

@Private
public class RegionServerAccounting
extends Object

RegionServerAccounting keeps record of some basic real time information about the Region Server. Currently, it keeps record the global memstore size and global memstore on-heap and off-heap overhead. It also tracks the replay edits per region.

Field Summary

Fields

Modifier and Type	Field	Description
private final LongAdder	globalMemStoreDataSize
private final LongAdder	globalMemStoreHeapSize
private long	globalMemStoreLimit
private long	globalMemStoreLimitLowMark
private final float	globalMemStoreLimitLowMarkPercent
private final LongAdder	globalMemStoreOffHeapSize
private long	globalOnHeapMemstoreLimit
private long	globalOnHeapMemstoreLimitLowMark
private final MemoryType	memType
private ConcurrentMap<String,Pair<Long,Long>>	retainedRegionRWRequestsCnt

Constructor Summary

Constructors

Constructor	Description
RegionServerAccounting(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	decGlobalMemStoreSize(long dataSizeDelta, long heapSizeDelta, long offHeapSizeDelta)
double	getFlushPressure()
long	getGlobalMemStoreDataSize()	Returns the global Memstore data size in the RegionServer
long	getGlobalMemStoreHeapSize()	Returns the global memstore on-heap size in the RegionServer
(package private) long	getGlobalMemStoreLimit()
(package private) long	getGlobalMemStoreLimitLowMark()
(package private) float	getGlobalMemStoreLimitLowMarkPercent()
long	getGlobalMemStoreOffHeapSize()	Returns the global memstore off-heap size in the RegionServer
(package private) long	getGlobalOffHeapMemStoreLimit()
(package private) long	getGlobalOnHeapMemStoreLimit()
protected ConcurrentMap<String,Pair<Long,Long>>	getRetainedRegionRWRequestsCnt()	Returns the retained metrics of region's read and write requests count
void	incGlobalMemStoreSize(long dataSizeDelta, long heapSizeDelta, long offHeapSizeDelta)
(package private) void	incGlobalMemStoreSize(MemStoreSize mss)
FlushType	isAboveHighWaterMark()	Return the FlushType if we are above the memstore high water mark
FlushType	isAboveLowWaterMark()	Return the FlushType if we're above the low watermark
(package private) boolean	isOffheap()
(package private) void	setGlobalMemStoreLimits(long newGlobalMemstoreLimit)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

globalMemStoreDataSize

private final LongAdder globalMemStoreDataSize

globalMemStoreHeapSize

private final LongAdder globalMemStoreHeapSize

globalMemStoreOffHeapSize

private final LongAdder globalMemStoreOffHeapSize

globalMemStoreLimit

private long globalMemStoreLimit

globalMemStoreLimitLowMarkPercent

private final float globalMemStoreLimitLowMarkPercent

globalMemStoreLimitLowMark

private long globalMemStoreLimitLowMark

memType

private final MemoryType memType

globalOnHeapMemstoreLimit

private long globalOnHeapMemstoreLimit

globalOnHeapMemstoreLimitLowMark

private long globalOnHeapMemstoreLimitLowMark

retainedRegionRWRequestsCnt

private ConcurrentMap<String,Pair<Long,Long>> retainedRegionRWRequestsCnt

Constructor Details

RegionServerAccounting

public RegionServerAccounting(org.apache.hadoop.conf.Configuration conf)

Method Details

getGlobalMemStoreLimit

long getGlobalMemStoreLimit()

getGlobalOffHeapMemStoreLimit

long getGlobalOffHeapMemStoreLimit()

getGlobalOnHeapMemStoreLimit

long getGlobalOnHeapMemStoreLimit()

setGlobalMemStoreLimits

void setGlobalMemStoreLimits(long newGlobalMemstoreLimit)

isOffheap

boolean isOffheap()

getGlobalMemStoreLimitLowMark

long getGlobalMemStoreLimitLowMark()

getGlobalMemStoreLimitLowMarkPercent

float getGlobalMemStoreLimitLowMarkPercent()

getGlobalMemStoreDataSize

public long getGlobalMemStoreDataSize()

Returns the global Memstore data size in the RegionServer

getGlobalMemStoreHeapSize

public long getGlobalMemStoreHeapSize()

Returns the global memstore on-heap size in the RegionServer

getGlobalMemStoreOffHeapSize

public long getGlobalMemStoreOffHeapSize()

Returns the global memstore off-heap size in the RegionServer

getRetainedRegionRWRequestsCnt

protected ConcurrentMap<String,Pair<Long,Long>> getRetainedRegionRWRequestsCnt()

Returns the retained metrics of region's read and write requests count

incGlobalMemStoreSize

void incGlobalMemStoreSize(MemStoreSize mss)

incGlobalMemStoreSize

public void incGlobalMemStoreSize(long dataSizeDelta,
 long heapSizeDelta,
 long offHeapSizeDelta)

decGlobalMemStoreSize

public void decGlobalMemStoreSize(long dataSizeDelta,
 long heapSizeDelta,
 long offHeapSizeDelta)

isAboveHighWaterMark

public FlushType isAboveHighWaterMark()

Return the FlushType if we are above the memstore high water mark

Returns:

the FlushType

isAboveLowWaterMark

public FlushType isAboveLowWaterMark()

Return the FlushType if we're above the low watermark

Returns:

the FlushType

getFlushPressure

public double getFlushPressure()

Returns:

the flush pressure of all stores on this regionserver. The value should be greater than or equal to 0.0, and any value greater than 1.0 means we enter the emergency state that global memstore size already exceeds lower limit.