org.apache.hadoop.hbase.quotas

Class RegionSizeReportingChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.quotas.RegionSizeReportingChore

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
public class RegionSizeReportingChore
extends ScheduledChore

A Chore which sends the region size reports on this RegionServer to the Master.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private MetricsRegionServer	metrics
(package private) static long	REGION_SIZE_REPORTING_CHORE_DELAY_DEFAULT
(package private) static String	REGION_SIZE_REPORTING_CHORE_DELAY_KEY
(package private) static int	REGION_SIZE_REPORTING_CHORE_PERIOD_DEFAULT
(package private) static String	REGION_SIZE_REPORTING_CHORE_PERIOD_KEY
(package private) static String	REGION_SIZE_REPORTING_CHORE_TIMEUNIT_DEFAULT
(package private) static String	REGION_SIZE_REPORTING_CHORE_TIMEUNIT_KEY
private RegionServerServices	rsServices

Constructor Summary

Constructors

Constructor and Description
RegionSizeReportingChore(RegionServerServices rsServices)

Method Summary

Modifier and Type	Method and Description
(package private) void	_chore()
protected void	chore() The task to execute on each scheduled execution of the Chore
(package private) static long	getInitialDelay(org.apache.hadoop.conf.Configuration conf) Extracts the initial delay for the chore from the configuration.
(package private) HashSet<RegionInfo>	getOnlineRegionInfos(List<? extends Region> onlineRegions)
(package private) static int	getPeriod(org.apache.hadoop.conf.Configuration conf) Extracts the period for the chore from the configuration.
(package private) static TimeUnit	getTimeUnit(org.apache.hadoop.conf.Configuration conf) Extracts the time unit for the chore period and initial delay from the configuration.
(package private) void	removeNonOnlineRegions(RegionSizeStore store, Set<RegionInfo> onlineRegions)

Methods inherited from class org.apache.hadoop.hbase.ScheduledChore

cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, shutdown, shutdown, toString, triggerNow

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

REGION_SIZE_REPORTING_CHORE_PERIOD_KEY

static final String REGION_SIZE_REPORTING_CHORE_PERIOD_KEY

See Also:

Constant Field Values

REGION_SIZE_REPORTING_CHORE_PERIOD_DEFAULT

static final int REGION_SIZE_REPORTING_CHORE_PERIOD_DEFAULT

See Also:

Constant Field Values

REGION_SIZE_REPORTING_CHORE_DELAY_KEY

static final String REGION_SIZE_REPORTING_CHORE_DELAY_KEY

See Also:

Constant Field Values

REGION_SIZE_REPORTING_CHORE_DELAY_DEFAULT

static final long REGION_SIZE_REPORTING_CHORE_DELAY_DEFAULT

See Also:

Constant Field Values

REGION_SIZE_REPORTING_CHORE_TIMEUNIT_KEY

static final String REGION_SIZE_REPORTING_CHORE_TIMEUNIT_KEY

See Also:

Constant Field Values

REGION_SIZE_REPORTING_CHORE_TIMEUNIT_DEFAULT

static final String REGION_SIZE_REPORTING_CHORE_TIMEUNIT_DEFAULT

rsServices

private final RegionServerServices rsServices

metrics

private final MetricsRegionServer metrics

Constructor Detail

RegionSizeReportingChore

public RegionSizeReportingChore(RegionServerServices rsServices)

Method Detail

chore

protected void chore()

Description copied from class: ScheduledChore

The task to execute on each scheduled execution of the Chore

Specified by:

chore in class ScheduledChore

_chore

void _chore()

getOnlineRegionInfos

HashSet<RegionInfo> getOnlineRegionInfos(List<? extends Region> onlineRegions)

removeNonOnlineRegions

void removeNonOnlineRegions(RegionSizeStore store,
                            Set<RegionInfo> onlineRegions)

getPeriod

static int getPeriod(org.apache.hadoop.conf.Configuration conf)

Extracts the period for the chore from the configuration.

Parameters:

conf - The configuration object.

Returns:

The configured chore period or the default value.

getInitialDelay

static long getInitialDelay(org.apache.hadoop.conf.Configuration conf)

Extracts the initial delay for the chore from the configuration.

Parameters:

conf - The configuration object.

Returns:

The configured chore initial delay or the default value.

getTimeUnit

static TimeUnit getTimeUnit(org.apache.hadoop.conf.Configuration conf)

Extracts the time unit for the chore period and initial delay from the configuration. The configuration value for REGION_SIZE_REPORTING_CHORE_TIMEUNIT_KEY must correspond to a TimeUnit value.

Parameters:

conf - The configuration object.

Returns:

The configured time unit for the chore period and initial delay or the default value.