Package org.apache.hadoop.hbase.regionserver

Class NonThreadSafeMemStoreSizing

java.lang.Object

org.apache.hadoop.hbase.regionserver.NonThreadSafeMemStoreSizing

All Implemented Interfaces:

MemStoreSizing

@Private
class NonThreadSafeMemStoreSizing
extends Object
implements MemStoreSizing

Accounting of current heap and data sizes. NOT THREAD SAFE. Use in a 'local' context only where just a single-thread is updating. No concurrency! Used, for example, when summing all Cells in a single batch where result is then applied to the Store.

See Also:

• ThreadSafeMemStoreSizing

Field Summary

Fields

Modifier and Type	Field	Description
private int	cellsCount
private long	dataSize
private long	heapSize
private long	offHeapSize

Fields inherited from interface org.apache.hadoop.hbase.regionserver.MemStoreSizing

DUD

Constructor Summary

Constructors

Constructor	Description
NonThreadSafeMemStoreSizing()
NonThreadSafeMemStoreSizing(long dataSize, long heapSize, long offHeapSize, int cellsCount)
NonThreadSafeMemStoreSizing(MemStoreSize mss)

Method Summary

Modifier and Type	Method	Description
boolean	compareAndSetDataSize(long expected, long updated)
int	getCellsCount()
long	getDataSize()
long	getHeapSize()
MemStoreSize	getMemStoreSize()
long	getOffHeapSize()
long	incMemStoreSize(long dataSizeDelta, long heapSizeDelta, long offHeapSizeDelta, int cellsCountDelta)	Returns The new dataSize ONLY as a convenience
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.regionserver.MemStoreSizing

decMemStoreSize, decMemStoreSize, incMemStoreSize

Field Details

dataSize

private long dataSize

heapSize

private long heapSize

offHeapSize

private long offHeapSize

cellsCount

private int cellsCount

Constructor Details

NonThreadSafeMemStoreSizing

NonThreadSafeMemStoreSizing()

NonThreadSafeMemStoreSizing

NonThreadSafeMemStoreSizing(MemStoreSize mss)

NonThreadSafeMemStoreSizing

NonThreadSafeMemStoreSizing(long dataSize,
 long heapSize,
 long offHeapSize,
 int cellsCount)

Method Details

getMemStoreSize

public MemStoreSize getMemStoreSize()

Specified by:

getMemStoreSize in interface MemStoreSizing

Returns:

Use this datastructure to return all three settings, MemStoreSizing.getDataSize(), MemStoreSizing.getHeapSize(), and MemStoreSizing.getOffHeapSize(), in the one go.

incMemStoreSize

public long incMemStoreSize(long dataSizeDelta,
 long heapSizeDelta,
 long offHeapSizeDelta,
 int cellsCountDelta)

Description copied from interface: MemStoreSizing

Returns The new dataSize ONLY as a convenience

Specified by:

incMemStoreSize in interface MemStoreSizing

compareAndSetDataSize

public boolean compareAndSetDataSize(long expected,
 long updated)

Specified by:

compareAndSetDataSize in interface MemStoreSizing

getDataSize

public long getDataSize()

Specified by:

getDataSize in interface MemStoreSizing

getHeapSize

public long getHeapSize()

Specified by:

getHeapSize in interface MemStoreSizing

getOffHeapSize

public long getOffHeapSize()

Specified by:

getOffHeapSize in interface MemStoreSizing

getCellsCount

public int getCellsCount()

Specified by:

getCellsCount in interface MemStoreSizing

toString

public String toString()

Overrides:

toString in class Object