org.apache.hadoop.hbase.regionserver

Class ThreadSafeMemStoreSizing

java.lang.Object

org.apache.hadoop.hbase.regionserver.ThreadSafeMemStoreSizing

All Implemented Interfaces:

MemStoreSizing

@InterfaceAudience.Private
class ThreadSafeMemStoreSizing
extends Object
implements MemStoreSizing

Accounting of current heap and data sizes. Thread-safe. Many threads can do updates against this single instance.

See Also:

NonThreadSafeMemStoreSizing, MemStoreSize

Field Summary

Fields

Modifier and Type	Field and Description
private AtomicInteger	cellsCount
private AtomicLong	dataSize
private AtomicLong	heapSize
private AtomicLong	offHeapSize

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

DUD

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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)
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 Detail

dataSize

private final AtomicLong dataSize

heapSize

private final AtomicLong heapSize

offHeapSize

private final AtomicLong offHeapSize

cellsCount

private final AtomicInteger cellsCount

Constructor Detail

ThreadSafeMemStoreSizing

ThreadSafeMemStoreSizing()

ThreadSafeMemStoreSizing

ThreadSafeMemStoreSizing(MemStoreSize mss)

ThreadSafeMemStoreSizing

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

Method Detail

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)

Specified by:

incMemStoreSize in interface MemStoreSizing

Returns:

The new dataSize ONLY as a convenience

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