@InterfaceAudience.Private public class RegionServerAccounting extends Object
Modifier and Type | Field and Description |
---|---|
private LongAdder |
globalMemStoreDataSize |
private LongAdder |
globalMemStoreHeapSize |
private long |
globalMemStoreLimit |
private long |
globalMemStoreLimitLowMark |
private float |
globalMemStoreLimitLowMarkPercent |
private LongAdder |
globalMemStoreOffHeapSize |
private long |
globalOnHeapMemstoreLimit |
private long |
globalOnHeapMemstoreLimitLowMark |
private MemoryType |
memType |
private ConcurrentMap<String,Pair<Long,Long>> |
retainedRegionRWRequestsCnt |
Constructor and Description |
---|
RegionServerAccounting(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and 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 heap size in the RegionServer
|
(package private) long |
getGlobalMemStoreLimit() |
(package private) long |
getGlobalMemStoreLimitLowMark() |
(package private) float |
getGlobalMemStoreLimitLowMarkPercent() |
long |
getGlobalMemStoreOffHeapSize()
Returns the global memstore 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) |
private final LongAdder globalMemStoreDataSize
private final LongAdder globalMemStoreHeapSize
private final LongAdder globalMemStoreOffHeapSize
private long globalMemStoreLimit
private final float globalMemStoreLimitLowMarkPercent
private long globalMemStoreLimitLowMark
private final MemoryType memType
private long globalOnHeapMemstoreLimit
private long globalOnHeapMemstoreLimitLowMark
private ConcurrentMap<String,Pair<Long,Long>> retainedRegionRWRequestsCnt
public RegionServerAccounting(org.apache.hadoop.conf.Configuration conf)
long getGlobalMemStoreLimit()
long getGlobalOffHeapMemStoreLimit()
long getGlobalOnHeapMemStoreLimit()
void setGlobalMemStoreLimits(long newGlobalMemstoreLimit)
boolean isOffheap()
long getGlobalMemStoreLimitLowMark()
float getGlobalMemStoreLimitLowMarkPercent()
public long getGlobalMemStoreDataSize()
public long getGlobalMemStoreHeapSize()
public long getGlobalMemStoreOffHeapSize()
protected ConcurrentMap<String,Pair<Long,Long>> getRetainedRegionRWRequestsCnt()
void incGlobalMemStoreSize(MemStoreSize mss)
public void incGlobalMemStoreSize(long dataSizeDelta, long heapSizeDelta, long offHeapSizeDelta)
public void decGlobalMemStoreSize(long dataSizeDelta, long heapSizeDelta, long offHeapSizeDelta)
public FlushType isAboveHighWaterMark()
public FlushType isAboveLowWaterMark()
public double getFlushPressure()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.