org.apache.hadoop.hbase.quotas

Class RegionSizeStoreImpl

java.lang.Object

org.apache.hadoop.hbase.quotas.RegionSizeStoreImpl

All Implemented Interfaces:

Iterable<Map.Entry<RegionInfo,RegionSize>>, HeapSize, RegionSizeStore

@InterfaceAudience.Private
public class RegionSizeStoreImpl
extends Object
implements RegionSizeStore

A RegionSizeStore implementation backed by a ConcurrentHashMap. We expected similar amounts of reads and writes to the "store", so using a RWLock is not going to provide any exceptional gains.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private static long	sizeOfEntry
private ConcurrentHashMap<RegionInfo,RegionSize>	store

Constructor Summary

Constructors

Constructor and Description
RegionSizeStoreImpl()

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all entries from the store.
RegionSize	getRegionSize(RegionInfo regionInfo) Returns the size for the give region if one exists.
long	heapSize()
void	incrementRegionSize(RegionInfo regionInfo, long delta) Atomically alter the size of a region.
boolean	isEmpty() Returns if the store is empty.
Iterator<Map.Entry<RegionInfo,RegionSize>>	iterator()
void	put(RegionInfo regionInfo, long size) Atomically sets the given size for a region.
RegionSize	remove(RegionInfo regionInfo) Removes the mapping for the given key, returning the value if one exists in the store.
int	size() Returns the number of entries in the store.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

LOG

private static final org.slf4j.Logger LOG

sizeOfEntry

private static final long sizeOfEntry

store

private final ConcurrentHashMap<RegionInfo,RegionSize> store

Constructor Detail

RegionSizeStoreImpl

public RegionSizeStoreImpl()

Method Detail

iterator

public Iterator<Map.Entry<RegionInfo,RegionSize>> iterator()

Specified by:

iterator in interface Iterable<Map.Entry<RegionInfo,RegionSize>>

getRegionSize

public RegionSize getRegionSize(RegionInfo regionInfo)

Description copied from interface: RegionSizeStore

Returns the size for the give region if one exists. If no size exists, null is returned.

Specified by:

getRegionSize in interface RegionSizeStore

Parameters:

regionInfo - The region whose size is being fetched.

Returns:

The size in bytes of the region or null if no size is stored.

put

public void put(RegionInfo regionInfo,
                long size)

Description copied from interface: RegionSizeStore

Atomically sets the given size for a region.

Specified by:

put in interface RegionSizeStore

Parameters:

regionInfo - An identifier for a region.

size - The size in bytes of the region.

incrementRegionSize

public void incrementRegionSize(RegionInfo regionInfo,
                                long delta)

Description copied from interface: RegionSizeStore

Atomically alter the size of a region.

Specified by:

incrementRegionSize in interface RegionSizeStore

Parameters:

regionInfo - The region to update.

delta - The change in size for the region, positive or negative.

remove

public RegionSize remove(RegionInfo regionInfo)

Description copied from interface: RegionSizeStore

Removes the mapping for the given key, returning the value if one exists in the store.

Specified by:

remove in interface RegionSizeStore

Parameters:

regionInfo - The key to remove from the store

Returns:

The value removed from the store if one exists, otherwise null.

heapSize

public long heapSize()

Specified by:

heapSize in interface HeapSize

Returns:

Approximate 'exclusive deep size' of implementing object. Includes count of payload and hosting object sizings.

size

public int size()

Description copied from interface: RegionSizeStore

Returns the number of entries in the store.

Specified by:

size in interface RegionSizeStore

Returns:

The number of entries in the store.

isEmpty

public boolean isEmpty()

Description copied from interface: RegionSizeStore

Returns if the store is empty.

Specified by:

isEmpty in interface RegionSizeStore

Returns:

true if there are no entries in the store, otherwise false.

clear

public void clear()

Description copied from interface: RegionSizeStore

Removes all entries from the store.

Specified by:

clear in interface RegionSizeStore