org.apache.hadoop.hbase.master.normalizer

Class RegionNormalizerManager

java.lang.Object

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

All Implemented Interfaces:

ConfigurationObserver, PropagatingConfigurationObserver

@InterfaceAudience.Private
public class RegionNormalizerManager
extends Object
implements PropagatingConfigurationObserver

This class encapsulates the details of the RegionNormalizer subsystem.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
RegionNormalizerManager(RegionNormalizerTracker regionNormalizerTracker, RegionNormalizerChore regionNormalizerChore, RegionNormalizerWorkQueue<TableName> workQueue, RegionNormalizerWorker worker)

Method Summary

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

LOG

private static final org.slf4j.Logger LOG

regionNormalizerTracker

private final RegionNormalizerTracker regionNormalizerTracker

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 Detail

RegionNormalizerManager

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

Method Detail

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)

Set region normalizer on/off

Parameters:

normalizerOn - whether normalizer should be on or off

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.