Package org.apache.hadoop.hbase.master.migrate

Class RollingUpgradeChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.master.migrate.RollingUpgradeChore

All Implemented Interfaces:

Runnable

@Private
public class RollingUpgradeChore
extends ScheduledChore

To avoid too many migrating/upgrade threads to be submitted at the time during master initialization, RollingUpgradeChore handles all rolling-upgrade tasks.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final int	CONCURRENT_PROCEDURES_COUNT
(package private) static final long	DEFAULT_ROLLING_UPGRADE_CHORE_DELAY_SECONDS
(package private) static final int	DFAULT_ROLLING_UPGRADE_CHORE_PERIOD_SECONDS
private static final org.slf4j.Logger	LOG
(package private) ProcedureExecutor<MasterProcedureEnv>	procedureExecutor
private List<InitializeStoreFileTrackerProcedure>	processingProcs
(package private) static final String	ROLLING_UPGRADE_CHORE_DELAY_SECONDS_KEY
(package private) static final String	ROLLING_UPGRADE_CHORE_PERIOD_SECONDS_KEY
private TableDescriptors	tableDescriptors

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RollingUpgradeChore(org.apache.hadoop.conf.Configuration conf, ProcedureExecutor<MasterProcedureEnv> procedureExecutor, TableDescriptors tableDescriptors, Stoppable stopper)
	RollingUpgradeChore(MasterServices masterServices)

Method Summary

Modifier and Type	Method	Description
protected void	chore()	The task to execute on each scheduled execution of the Chore
private boolean	isCompletelyMigrateSFT(int concurrentCount)

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

ROLLING_UPGRADE_CHORE_PERIOD_SECONDS_KEY

static final String ROLLING_UPGRADE_CHORE_PERIOD_SECONDS_KEY

See Also:

• Constant Field Values

DFAULT_ROLLING_UPGRADE_CHORE_PERIOD_SECONDS

static final int DFAULT_ROLLING_UPGRADE_CHORE_PERIOD_SECONDS

See Also:

• Constant Field Values

ROLLING_UPGRADE_CHORE_DELAY_SECONDS_KEY

static final String ROLLING_UPGRADE_CHORE_DELAY_SECONDS_KEY

See Also:

• Constant Field Values

DEFAULT_ROLLING_UPGRADE_CHORE_DELAY_SECONDS

static final long DEFAULT_ROLLING_UPGRADE_CHORE_DELAY_SECONDS

See Also:

• Constant Field Values

CONCURRENT_PROCEDURES_COUNT

static final int CONCURRENT_PROCEDURES_COUNT

See Also:

• Constant Field Values

LOG

private static final org.slf4j.Logger LOG

procedureExecutor

ProcedureExecutor<MasterProcedureEnv> procedureExecutor

tableDescriptors

private TableDescriptors tableDescriptors

processingProcs

private List<InitializeStoreFileTrackerProcedure> processingProcs

Constructor Details

RollingUpgradeChore

public RollingUpgradeChore(MasterServices masterServices)

RollingUpgradeChore

private RollingUpgradeChore(org.apache.hadoop.conf.Configuration conf,
 ProcedureExecutor<MasterProcedureEnv> procedureExecutor,
 TableDescriptors tableDescriptors,
 Stoppable stopper)

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

isCompletelyMigrateSFT

private boolean isCompletelyMigrateSFT(int concurrentCount)