Package org.apache.hadoop.hbase.mapreduce

Class RegionSizeCalculator

java.lang.Object

org.apache.hadoop.hbase.mapreduce.RegionSizeCalculator

@Private
public class RegionSizeCalculator
extends Object

Computes size of each region for given table and given column families. The value is used by MapReduce for better scheduling.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final String	ENABLE_REGIONSIZECALCULATOR
private static final org.slf4j.Logger	LOG
private static final long	MEGABYTE
private final Map<byte[],Long>	sizeMap	Maps each region to its size in bytes.

Constructor Summary

Constructors

Constructor	Description
RegionSizeCalculator(RegionLocator regionLocator, Admin admin)	Computes size of each region for table and given column families.

Method Summary

Modifier and Type	Method	Description
(package private) boolean	enabled(org.apache.hadoop.conf.Configuration configuration)
private Set<ServerName>	getRegionServersOfTable(RegionLocator regionLocator)
long	getRegionSize(byte[] regionId)	Returns size of given region in bytes.
Map<byte[],Long>	getRegionSizeMap()
private void	init(RegionLocator regionLocator, Admin admin)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

sizeMap

private final Map<byte[],Long> sizeMap

Maps each region to its size in bytes.

ENABLE_REGIONSIZECALCULATOR

static final String ENABLE_REGIONSIZECALCULATOR

See Also:

• Constant Field Values

MEGABYTE

private static final long MEGABYTE

See Also:

• Constant Field Values

Constructor Details

RegionSizeCalculator

public RegionSizeCalculator(RegionLocator regionLocator,
 Admin admin)
                     throws IOException

Computes size of each region for table and given column families.

Throws:

IOException

Method Details

init

private void init(RegionLocator regionLocator,
 Admin admin)
           throws IOException

Throws:

IOException

getRegionServersOfTable

private Set<ServerName> getRegionServersOfTable(RegionLocator regionLocator)
                                         throws IOException

Throws:

IOException

enabled

boolean enabled(org.apache.hadoop.conf.Configuration configuration)

getRegionSize

public long getRegionSize(byte[] regionId)

Returns size of given region in bytes. Returns 0 if region was not found.

getRegionSizeMap

public Map<byte[],Long> getRegionSizeMap()