org.apache.hadoop.hbase.regionserver

Class RegionServicesForStores

java.lang.Object

org.apache.hadoop.hbase.regionserver.RegionServicesForStores

@InterfaceAudience.Private
public class RegionServicesForStores
extends Object

Services a Store needs from a Region. RegionServicesForStores class is the interface through which memstore access services at the region level. For example, when using alternative memory formats or due to compaction the memstore needs to take occasional lock and update size counters at the region level.

Field Summary

Fields

Modifier and Type	Field and Description
private static ThreadPoolExecutor	INMEMORY_COMPACTION_POOL_FOR_TEST
private int	inMemoryPoolSize
private HRegion	region
private RegionServerServices	rsServices

Constructor Summary

Constructors

Constructor and Description
RegionServicesForStores(HRegion region, RegionServerServices rsServices)

Method Summary

Modifier and Type	Method and Description
void	addMemStoreSize(long dataSizeDelta, long heapSizeDelta, long offHeapSizeDelta, int cellsCountDelta)
void	blockUpdates()
(package private) ThreadPoolExecutor	getInMemoryCompactionPool()
private static ThreadPoolExecutor	getInMemoryCompactionPoolForTest()
long	getMemStoreFlushSize()
(package private) long	getMemStoreSize()
int	getNumStores()
RegionInfo	getRegionInfo()
WAL	getWAL()
void	unblockUpdates()

Methods inherited from class java.lang.Object

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

Field Detail

region

private final HRegion region

rsServices

private final RegionServerServices rsServices

inMemoryPoolSize

private int inMemoryPoolSize

INMEMORY_COMPACTION_POOL_FOR_TEST

private static ThreadPoolExecutor INMEMORY_COMPACTION_POOL_FOR_TEST

Constructor Detail

RegionServicesForStores

public RegionServicesForStores(HRegion region,
                               RegionServerServices rsServices)

Method Detail

blockUpdates

public void blockUpdates()

unblockUpdates

public void unblockUpdates()

addMemStoreSize

public void addMemStoreSize(long dataSizeDelta,
                            long heapSizeDelta,
                            long offHeapSizeDelta,
                            int cellsCountDelta)

getRegionInfo

public RegionInfo getRegionInfo()

getWAL

public WAL getWAL()

getInMemoryCompactionPoolForTest

private static ThreadPoolExecutor getInMemoryCompactionPoolForTest()

getInMemoryCompactionPool

ThreadPoolExecutor getInMemoryCompactionPool()

getMemStoreFlushSize

public long getMemStoreFlushSize()

getNumStores

public int getNumStores()

getMemStoreSize

long getMemStoreSize()