Package org.apache.hadoop.hbase.master.normalizer

Class RegionNormalizerManager

java.lang.Object

org.apache.hadoop.hbase.master.normalizer.RegionNormalizerManager

All Implemented Interfaces:

ConfigurationObserver, PropagatingConfigurationObserver

@Private
public class RegionNormalizerManager
extends Object
implements PropagatingConfigurationObserver

This class encapsulates the details of the RegionNormalizer subsystem.

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final ExecutorService	pool
private final RegionNormalizerChore	regionNormalizerChore
private final RegionNormalizerStateStore	regionNormalizerStateStore
private boolean	started
private final Object	startStopLock
private boolean	stopped
private final RegionNormalizerWorker	worker
private final RegionNormalizerWorkQueue<TableName>	workQueue

Constructor Summary

Constructors

Constructor	Description
RegionNormalizerManager(RegionNormalizerStateStore regionNormalizerStateStore, RegionNormalizerChore regionNormalizerChore, RegionNormalizerWorkQueue<TableName> workQueue, RegionNormalizerWorker worker)

Method Summary

Modifier and Type	Method	Description
void	deregisterChildren(ConfigurationManager manager)	Needs to be called to deregister the children from the manager.
long	getMergePlanCount()	Return the number of times a MergeNormalizationPlan has been submitted.
ScheduledChore	getRegionNormalizerChore()
long	getSkippedCount(NormalizationPlan.PlanType type)	Retrieve a count of the number of times plans of type type were submitted but skipped.
long	getSplitPlanCount()	Return the number of times a SplitNormalizationPlan has been submitted.
boolean	isNormalizerOn()	Return true if region normalizer is on, false otherwise
boolean	normalizeRegions(List<TableName> tables, boolean isHighPriority)	Submit tables for normalization.
void	onConfigurationChange(org.apache.hadoop.conf.Configuration conf)	This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.
void	planSkipped(NormalizationPlan.PlanType type)	Call-back for the case where plan couldn't be executed due to constraint violation, such as namespace quota.
void	registerChildren(ConfigurationManager manager)	Needs to be called to register the children to the manager.
void	setNormalizerOn(boolean normalizerOn)	Set region normalizer on/off
void	start()
void	stop()

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

regionNormalizerStateStore

private final RegionNormalizerStateStore regionNormalizerStateStore

regionNormalizerChore

private final RegionNormalizerChore regionNormalizerChore

workQueue

private final RegionNormalizerWorkQueue<TableName> workQueue

worker

private final RegionNormalizerWorker worker

pool

private final ExecutorService pool

startStopLock

private final Object startStopLock

started

private boolean started

stopped

private boolean stopped

Constructor Details

RegionNormalizerManager

RegionNormalizerManager(@NonNull
 RegionNormalizerStateStore regionNormalizerStateStore,
 @Nullable
 RegionNormalizerChore regionNormalizerChore,
 @Nullable
 RegionNormalizerWorkQueue<TableName> workQueue,
 @Nullable
 RegionNormalizerWorker worker)

Method Details

registerChildren

public void registerChildren(ConfigurationManager manager)

Description copied from interface: PropagatingConfigurationObserver

Needs to be called to register the children to the manager.

Specified by:

registerChildren in interface PropagatingConfigurationObserver

Parameters:

manager - : to register to

deregisterChildren

public void deregisterChildren(ConfigurationManager manager)

Description copied from interface: PropagatingConfigurationObserver

Needs to be called to deregister the children from the manager.

Specified by:

deregisterChildren in interface PropagatingConfigurationObserver

Parameters:

manager - : to deregister from

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: ConfigurationObserver

This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.

Specified by:

onConfigurationChange in interface ConfigurationObserver

start

public void start()

stop

public void stop()

getRegionNormalizerChore

public ScheduledChore getRegionNormalizerChore()

isNormalizerOn

public boolean isNormalizerOn()

Return true if region normalizer is on, false otherwise

setNormalizerOn

public void setNormalizerOn(boolean normalizerOn)
                     throws IOException

Set region normalizer on/off

Parameters:

normalizerOn - whether normalizer should be on or off

Throws:

IOException

planSkipped

public void planSkipped(NormalizationPlan.PlanType type)

Call-back for the case where plan couldn't be executed due to constraint violation, such as namespace quota.

Parameters:

type - type of plan that was skipped.

getSkippedCount

public long getSkippedCount(NormalizationPlan.PlanType type)

Retrieve a count of the number of times plans of type type were submitted but skipped.

Parameters:

type - type of plan for which skipped count is to be returned

getSplitPlanCount

public long getSplitPlanCount()

Return the number of times a SplitNormalizationPlan has been submitted.

getMergePlanCount

public long getMergePlanCount()

Return the number of times a MergeNormalizationPlan has been submitted.

normalizeRegions

public boolean normalizeRegions(List<TableName> tables,
 boolean isHighPriority)

Submit tables for normalization.

Parameters:

tables - a list of tables to submit.

isHighPriority - true when these requested tables should skip to the front of the queue.

Returns:

true when work was queued, false otherwise.