Package 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

@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	Description
private static final org.slf4j.Logger	LOG
private final MetricsRegionServer	metrics
(package private) static final long	REGION_SIZE_REPORTING_CHORE_DELAY_DEFAULT
(package private) static final String	REGION_SIZE_REPORTING_CHORE_DELAY_KEY
(package private) static final int	REGION_SIZE_REPORTING_CHORE_PERIOD_DEFAULT
(package private) static final String	REGION_SIZE_REPORTING_CHORE_PERIOD_KEY
(package private) static final String	REGION_SIZE_REPORTING_CHORE_TIMEUNIT_DEFAULT
(package private) static final String	REGION_SIZE_REPORTING_CHORE_TIMEUNIT_KEY
private final RegionServerServices	rsServices

Constructor Summary

Constructors

Constructor	Description
RegionSizeReportingChore(RegionServerServices rsServices)

Method Summary

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

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 Details

RegionSizeReportingChore

public RegionSizeReportingChore(RegionServerServices rsServices)

Method Details

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.