org.apache.hadoop.hbase.mapreduce

Class RegionSizeCalculator

java.lang.Object

org.apache.hadoop.hbase.mapreduce.RegionSizeCalculator

@InterfaceAudience.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 and Description
(package private) static String	ENABLE_REGIONSIZECALCULATOR
private static org.slf4j.Logger	LOG
private static long	MEGABYTE
private Map<byte[],Long>	sizeMap Maps each region to its size in bytes.

Constructor Summary

Constructors

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

Method Summary

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

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 Detail

RegionSizeCalculator

public RegionSizeCalculator(RegionLocator regionLocator,
                            Admin admin)
                     throws IOException

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

Throws:

IOException

Method Detail

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()