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

@InterfaceAudience.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 and Description
(package private) static int	CONCURRENT_PROCEDURES_COUNT
(package private) static long	DEFAULT_ROLLING_UPGRADE_CHORE_DELAY_SECONDS
(package private) static int	DFAULT_ROLLING_UPGRADE_CHORE_PERIOD_SECONDS
private static org.slf4j.Logger	LOG
(package private) ProcedureExecutor<MasterProcedureEnv>	procedureExecutor
private List<InitializeStoreFileTrackerProcedure>	processingProcs
(package private) static String	ROLLING_UPGRADE_CHORE_DELAY_SECONDS_KEY
(package private) static String	ROLLING_UPGRADE_CHORE_PERIOD_SECONDS_KEY
private TableDescriptors	tableDescriptors

Constructor Summary

Constructors

Modifier	Constructor and 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 and 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 Detail

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 Detail

RollingUpgradeChore

public RollingUpgradeChore(MasterServices masterServices)

RollingUpgradeChore

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

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

isCompletelyMigrateSFT

private boolean isCompletelyMigrateSFT(int concurrentCount)