Uses of Class
org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv

Packages that use MasterProcedureEnv

Package	Description
org.apache.hadoop.hbase.master
org.apache.hadoop.hbase.master.assignment
org.apache.hadoop.hbase.master.locking
org.apache.hadoop.hbase.master.procedure
org.apache.hadoop.hbase.master.replication

Uses of MasterProcedureEnv in org.apache.hadoop.hbase.master

Fields in org.apache.hadoop.hbase.master with type parameters of type MasterProcedureEnv

Modifier and Type	Field and Description
private ProcedureExecutor<MasterProcedureEnv>	HMaster.procedureExecutor

Methods in org.apache.hadoop.hbase.master that return types with arguments of type MasterProcedureEnv

Modifier and Type	Method and Description
ProcedureExecutor<MasterProcedureEnv>	MasterServices.getMasterProcedureExecutor()
ProcedureExecutor<MasterProcedureEnv>	HMaster.getMasterProcedureExecutor()
private RemoteProcedureDispatcher.RemoteProcedure<MasterProcedureEnv,?>	HMaster.getRemoteProcedure(long procId)

Method parameters in org.apache.hadoop.hbase.master with type arguments of type MasterProcedureEnv

Modifier and Type	Method and Description
private void	HMaster.checkUnsupportedProcedure(Map<Class<? extends Procedure>,List<Procedure<MasterProcedureEnv>>> procsByType) In HBASE-20811, we have introduced a new TRSP to assign/unassign/move regions, and it is incompatible with the old AssignProcedure/UnassignProcedure/MoveRegionProcedure.
void	MasterCoprocessorHost.preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv, long procId)
private long	ClusterSchemaServiceImpl.submitProcedure(Procedure<MasterProcedureEnv> procedure, NonceKey nonceKey)

Uses of MasterProcedureEnv in org.apache.hadoop.hbase.master.assignment

Methods in org.apache.hadoop.hbase.master.assignment that return MasterProcedureEnv

Modifier and Type	Method and Description
private MasterProcedureEnv	AssignmentManager.getProcedureEnvironment()

Methods in org.apache.hadoop.hbase.master.assignment with parameters of type MasterProcedureEnv

Modifier and Type	Method and Description
protected boolean	SplitTableRegionProcedure.abort(MasterProcedureEnv env)
protected boolean	MergeTableRegionsProcedure.abort(MasterProcedureEnv env)
protected boolean	RegionRemoteProcedureBase.abort(MasterProcedureEnv env)
boolean	MoveRegionProcedure.abort(MasterProcedureEnv env) Deprecated.
protected boolean	RegionTransitionProcedure.abort(MasterProcedureEnv env) Deprecated.
protected Procedure.LockState	SplitTableRegionProcedure.acquireLock(MasterProcedureEnv env)
protected Procedure.LockState	MergeTableRegionsProcedure.acquireLock(MasterProcedureEnv env)
protected void	RegionRemoteProcedureBase.afterReplay(MasterProcedureEnv env)
static TransitRegionStateProcedure	TransitRegionStateProcedure.assign(MasterProcedureEnv env, RegionInfo region, boolean forceNewPlan, ServerName targetServer)
static TransitRegionStateProcedure	TransitRegionStateProcedure.assign(MasterProcedureEnv env, RegionInfo region, ServerName targetServer)
(package private) static void	AssignmentManagerUtil.checkClosedRegion(MasterProcedureEnv env, RegionInfo regionInfo)
private void	SplitTableRegionProcedure.checkClosedRegions(MasterProcedureEnv env)
private void	MergeTableRegionsProcedure.checkClosedRegions(MasterProcedureEnv env)
private static void	MergeTableRegionsProcedure.checkRegionsToMerge(MasterProcedureEnv env, RegionInfo[] regions, boolean force)
private void	SplitTableRegionProcedure.checkSplittable(MasterProcedureEnv env, RegionInfo regionToSplit, byte[] splitRow) Check whether the region is splittable
private void	MergeTableRegionsProcedure.cleanupMergedRegion(MasterProcedureEnv env) Clean up a merged region on rollback after failure.
private void	TransitRegionStateProcedure.closeRegion(MasterProcedureEnv env, RegionStateNode regionNode)
private StateMachineProcedure.Flow	TransitRegionStateProcedure.confirmClosed(MasterProcedureEnv env, RegionStateNode regionNode)
private StateMachineProcedure.Flow	TransitRegionStateProcedure.confirmOpened(MasterProcedureEnv env, RegionStateNode regionNode)
private TransitRegionStateProcedure[]	SplitTableRegionProcedure.createAssignProcedures(MasterProcedureEnv env)
private TransitRegionStateProcedure[]	MergeTableRegionsProcedure.createAssignProcedures(MasterProcedureEnv env)
private static TransitRegionStateProcedure[]	AssignmentManagerUtil.createAssignProcedures(MasterProcedureEnv env, List<RegionInfo> regions, int regionReplication, ServerName targetServer, boolean ignoreIfInTransition) Create assign procedures for the give regions, according to the regionReplication.
(package private) static TransitRegionStateProcedure[]	AssignmentManagerUtil.createAssignProceduresForOpeningNewRegions(MasterProcedureEnv env, List<RegionInfo> regions, int regionReplication, ServerName targetServer)
void	SplitTableRegionProcedure.createDaughterRegions(MasterProcedureEnv env) Create daughter regions
private GCRegionProcedure[]	GCMergedRegionsProcedure.createGCRegionProcedures(MasterProcedureEnv env) Deprecated.
private GCRegionProcedure[]	GCMultipleMergedRegionsProcedure.createGCRegionProcedures(MasterProcedureEnv env)
private void	MergeTableRegionsProcedure.createMergedRegion(MasterProcedureEnv env) Create merged region.
private TransitRegionStateProcedure[]	SplitTableRegionProcedure.createUnassignProcedures(MasterProcedureEnv env)
private TransitRegionStateProcedure[]	MergeTableRegionsProcedure.createUnassignProcedures(MasterProcedureEnv env)
(package private) static TransitRegionStateProcedure[]	AssignmentManagerUtil.createUnassignProceduresForSplitOrMerge(MasterProcedureEnv env, Stream<RegionInfo> regions, int regionReplication)
protected Procedure[]	TransitRegionStateProcedure.execute(MasterProcedureEnv env)
protected Procedure<MasterProcedureEnv>[]	RegionRemoteProcedureBase.execute(MasterProcedureEnv env)
protected Procedure[]	RegionTransitionProcedure.execute(MasterProcedureEnv env) Deprecated.
protected StateMachineProcedure.Flow	GCMergedRegionsProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCMergedRegionsState state) Deprecated.
protected StateMachineProcedure.Flow	GCMultipleMergedRegionsProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCMergedRegionsState state)
protected StateMachineProcedure.Flow	GCRegionProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCRegionState state)
protected StateMachineProcedure.Flow	MergeTableRegionsProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MergeTableRegionsState state)
protected StateMachineProcedure.Flow	MoveRegionProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MoveRegionState state) Deprecated.
protected StateMachineProcedure.Flow	TransitRegionStateProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RegionStateTransitionState state)
protected StateMachineProcedure.Flow	SplitTableRegionProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitTableRegionState state)
protected void	UnassignProcedure.finishTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
protected void	AssignProcedure.finishTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
protected abstract void	RegionTransitionProcedure.finishTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
private TransitRegionStateProcedure	RegionRemoteProcedureBase.getParent(MasterProcedureEnv env)
private ServerName	SplitTableRegionProcedure.getParentRegionServerName(MasterProcedureEnv env)
protected ProcedureMetrics	CloseRegionProcedure.getProcedureMetrics(MasterProcedureEnv env)
protected ProcedureMetrics	UnassignProcedure.getProcedureMetrics(MasterProcedureEnv env) Deprecated.
protected ProcedureMetrics	OpenRegionProcedure.getProcedureMetrics(MasterProcedureEnv env)
protected ProcedureMetrics	SplitTableRegionProcedure.getProcedureMetrics(MasterProcedureEnv env)
protected ProcedureMetrics	MergeTableRegionsProcedure.getProcedureMetrics(MasterProcedureEnv env)
protected ProcedureMetrics	TransitRegionStateProcedure.getProcedureMetrics(MasterProcedureEnv env)
protected ProcedureMetrics	AssignProcedure.getProcedureMetrics(MasterProcedureEnv env) Deprecated.
(package private) static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse	AssignmentManagerUtil.getRegionInfoResponse(MasterProcedureEnv env, ServerName regionLocation, RegionInfo hri) Raw call to remote regionserver to get info on a particular region.
(package private) static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse	AssignmentManagerUtil.getRegionInfoResponse(MasterProcedureEnv env, ServerName regionLocation, RegionInfo hri, boolean includeBestSplitRow)
private RegionStateNode	RegionRemoteProcedureBase.getRegionNode(MasterProcedureEnv env)
private int	SplitTableRegionProcedure.getRegionReplication(MasterProcedureEnv env)
private int	MergeTableRegionsProcedure.getRegionReplication(MasterProcedureEnv env)
RegionStateNode	RegionTransitionProcedure.getRegionState(MasterProcedureEnv env) Deprecated.
private RegionStateNode	TransitRegionStateProcedure.getRegionStateNode(MasterProcedureEnv env)
private ServerName	MergeTableRegionsProcedure.getServerName(MasterProcedureEnv env) The procedure could be restarted from a different machine.
protected boolean	MergeTableRegionsProcedure.holdLock(MasterProcedureEnv env)
private boolean	MergeTableRegionsProcedure.isMergeable(MasterProcedureEnv env, RegionState rs)
private void	MergeTableRegionsProcedure.mergeStoreFiles(MasterProcedureEnv env, HRegionFileSystem regionFs, org.apache.hadoop.fs.Path mergeDir) Create reference file(s) to parent region hfiles in the mergeDir
static TransitRegionStateProcedure	TransitRegionStateProcedure.move(MasterProcedureEnv env, RegionInfo region, ServerName targetServer)
private void	SplitTableRegionProcedure.openParentRegion(MasterProcedureEnv env) Rollback close parent region
private void	TransitRegionStateProcedure.openRegion(MasterProcedureEnv env, RegionStateNode regionNode)
protected void	AssignmentManager.RegionInTransitionChore.periodicExecute(MasterProcedureEnv env)
protected void	AssignmentManager.DeadServerMetricRegionChore.periodicExecute(MasterProcedureEnv env)
private void	RegionRemoteProcedureBase.persistAndWake(MasterProcedureEnv env, RegionStateNode regionNode)
private void	MergeTableRegionsProcedure.postCompletedMergeRegions(MasterProcedureEnv env) Post merge region action
private void	MergeTableRegionsProcedure.postMergeRegionsCommit(MasterProcedureEnv env) Post merge region action
private void	MergeTableRegionsProcedure.postRollBackMergeRegions(MasterProcedureEnv env) Action after rollback a merge table regions action.
private void	SplitTableRegionProcedure.postRollBackSplitRegion(MasterProcedureEnv env) Action after rollback a split table region action.
private void	SplitTableRegionProcedure.postSplitRegion(MasterProcedureEnv env) Post split region actions
private void	MergeTableRegionsProcedure.preMergeRegions(MasterProcedureEnv env) Pre merge region action
private void	MergeTableRegionsProcedure.preMergeRegionsCommit(MasterProcedureEnv env) Post merge region action
private boolean	MergeTableRegionsProcedure.prepareMergeRegion(MasterProcedureEnv env) Prepare merge and do some check
boolean	SplitTableRegionProcedure.prepareSplitRegion(MasterProcedureEnv env) Prepare to Split region.
private void	SplitTableRegionProcedure.preSplitRegion(MasterProcedureEnv env) Action before splitting region in a table.
private void	SplitTableRegionProcedure.preSplitRegionAfterMETA(MasterProcedureEnv env) Pre split region actions after the Point-of-No-Return step
private void	SplitTableRegionProcedure.preSplitRegionBeforeMETA(MasterProcedureEnv env) Post split region actions before the Point-of-No-Return step
private void	TransitRegionStateProcedure.queueAssign(MasterProcedureEnv env, RegionStateNode regionNode)
protected void	SplitTableRegionProcedure.releaseLock(MasterProcedureEnv env)
protected void	MergeTableRegionsProcedure.releaseLock(MasterProcedureEnv env)
Optional<RemoteProcedureDispatcher.RemoteOperation>	UnassignProcedure.remoteCallBuild(MasterProcedureEnv env, ServerName serverName) Deprecated.
Optional<RemoteProcedureDispatcher.RemoteOperation>	AssignProcedure.remoteCallBuild(MasterProcedureEnv env, ServerName serverName) Deprecated.
Optional<RemoteProcedureDispatcher.RemoteOperation>	RegionRemoteProcedureBase.remoteCallBuild(MasterProcedureEnv env, ServerName remote)
abstract Optional<RemoteProcedureDispatcher.RemoteOperation>	RegionTransitionProcedure.remoteCallBuild(MasterProcedureEnv env, ServerName serverName) Deprecated.
protected boolean	UnassignProcedure.remoteCallFailed(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.
protected boolean	AssignProcedure.remoteCallFailed(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.
protected abstract boolean	RegionTransitionProcedure.remoteCallFailed(MasterProcedureEnv env, RegionStateNode regionNode, IOException exception) Deprecated.
void	RegionRemoteProcedureBase.remoteCallFailed(MasterProcedureEnv env, ServerName remote, IOException exception)
void	RegionTransitionProcedure.remoteCallFailed(MasterProcedureEnv env, ServerName serverName, IOException exception) Deprecated.
void	RegionRemoteProcedureBase.remoteOperationCompleted(MasterProcedureEnv env)
void	RegionTransitionProcedure.remoteOperationCompleted(MasterProcedureEnv env) Deprecated.
void	RegionRemoteProcedureBase.remoteOperationFailed(MasterProcedureEnv env, RemoteProcedureException error)
void	RegionTransitionProcedure.remoteOperationFailed(MasterProcedureEnv env, RemoteProcedureException error) Deprecated.
private void	SplitTableRegionProcedure.removeNonDefaultReplicas(MasterProcedureEnv env)
private void	MergeTableRegionsProcedure.removeNonDefaultReplicas(MasterProcedureEnv env)
(package private) static void	AssignmentManagerUtil.removeNonDefaultReplicas(MasterProcedureEnv env, Stream<RegionInfo> regions, int regionReplication)
static TransitRegionStateProcedure	TransitRegionStateProcedure.reopen(MasterProcedureEnv env, RegionInfo region)
(package private) static void	AssignmentManagerUtil.reopenRegionsForRollback(MasterProcedureEnv env, List<RegionInfo> regions, int regionReplication, ServerName targetServer)
protected void	UnassignProcedure.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId) Deprecated.
protected void	AssignProcedure.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long openSeqNum) Deprecated.
protected abstract void	RegionTransitionProcedure.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId) Deprecated.
(package private) void	RegionRemoteProcedureBase.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId)
void	TransitRegionStateProcedure.reportTransition(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code, long seqId, long procId)
protected void	RegionRemoteProcedureBase.rollback(MasterProcedureEnv env)
protected void	RegionTransitionProcedure.rollback(MasterProcedureEnv env) Deprecated.
private void	MergeTableRegionsProcedure.rollbackCloseRegionsForMerge(MasterProcedureEnv env) Rollback close regions
protected void	GCMergedRegionsProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCMergedRegionsState state) Deprecated.
protected void	GCMultipleMergedRegionsProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCMergedRegionsState state)
protected void	GCRegionProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCRegionState state)
protected void	MergeTableRegionsProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MergeTableRegionsState state) To rollback MergeTableRegionsProcedure, two AssignProcedures are asynchronously submitted for each region to be merged (rollback doesn't wait on the completion of the AssignProcedures) .
protected void	MoveRegionProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MoveRegionState state) Deprecated.
protected void	TransitRegionStateProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RegionStateTransitionState state)
protected void	SplitTableRegionProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitTableRegionState state) To rollback SplitTableRegionProcedure, an AssignProcedure is asynchronously submitted for parent region to be split (rollback doesn't wait on the completion of the AssignProcedure) .
void	TransitRegionStateProcedure.serverCrashed(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName)
(package private) void	RegionRemoteProcedureBase.serverCrashed(MasterProcedureEnv env, RegionStateNode regionNode, ServerName serverName)
private static TransitRegionStateProcedure	TransitRegionStateProcedure.setOwner(MasterProcedureEnv env, TransitRegionStateProcedure proc)
private void	MergeTableRegionsProcedure.setRegionStateToMerging(MasterProcedureEnv env) Set the region states to MERGING state
protected boolean	TransitRegionStateProcedure.setTimeoutFailure(MasterProcedureEnv env) At end of timeout, wake ourselves up so we run again.
protected boolean	RegionRemoteProcedureBase.setTimeoutFailure(MasterProcedureEnv env)
private Pair<Integer,Integer>	SplitTableRegionProcedure.splitStoreFiles(MasterProcedureEnv env, HRegionFileSystem regionFs) Create Split directory
protected boolean	UnassignProcedure.startTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
protected boolean	AssignProcedure.startTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
protected abstract boolean	RegionTransitionProcedure.startTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
static TransitRegionStateProcedure	TransitRegionStateProcedure.unassign(MasterProcedureEnv env, RegionInfo region)
private void	RegionRemoteProcedureBase.unattach(MasterProcedureEnv env)
private void	SplitTableRegionProcedure.updateMeta(MasterProcedureEnv env) Add daughter regions to META
private void	MergeTableRegionsProcedure.updateMetaForMergedRegions(MasterProcedureEnv env) Add merged region to META and delete original regions.
protected boolean	UnassignProcedure.updateTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
protected boolean	AssignProcedure.updateTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
protected abstract boolean	RegionTransitionProcedure.updateTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.
protected void	CloseRegionProcedure.updateTransitionWithoutPersistingToMeta(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId)
protected void	OpenRegionProcedure.updateTransitionWithoutPersistingToMeta(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long openSeqNum)
protected abstract void	RegionRemoteProcedureBase.updateTransitionWithoutPersistingToMeta(MasterProcedureEnv env, RegionStateNode regionNode, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode transitionCode, long seqId)
protected boolean	TransitRegionStateProcedure.waitInitialized(MasterProcedureEnv env)
protected boolean	RegionRemoteProcedureBase.waitInitialized(MasterProcedureEnv env)
private void	SplitTableRegionProcedure.writeMaxSequenceIdFile(MasterProcedureEnv env)
private void	MergeTableRegionsProcedure.writeMaxSequenceIdFile(MasterProcedureEnv env)

Constructors in org.apache.hadoop.hbase.master.assignment with parameters of type MasterProcedureEnv

Constructor and Description
GCMergedRegionsProcedure(MasterProcedureEnv env, RegionInfo mergedChild, RegionInfo father, RegionInfo mother) Deprecated.
GCMultipleMergedRegionsProcedure(MasterProcedureEnv env, RegionInfo mergedChild, List<RegionInfo> parents)
GCRegionProcedure(MasterProcedureEnv env, RegionInfo hri)
MergeTableRegionsProcedure(MasterProcedureEnv env, RegionInfo[] regionsToMerge, boolean force)
SplitTableRegionProcedure(MasterProcedureEnv env, RegionInfo regionToSplit, byte[] splitRow)
TransitRegionStateProcedure(MasterProcedureEnv env, RegionInfo hri, ServerName assignCandidate, boolean forceNewPlan, TransitRegionStateProcedure.TransitionType type)

Uses of MasterProcedureEnv in org.apache.hadoop.hbase.master.locking

Methods in org.apache.hadoop.hbase.master.locking with parameters of type MasterProcedureEnv

Modifier and Type	Method and Description
protected boolean	LockProcedure.abort(MasterProcedureEnv env)
protected Procedure.LockState	LockProcedure.acquireLock(MasterProcedureEnv env)
boolean	LockProcedure.LockInterface.acquireLock(MasterProcedureEnv env)
boolean	LockProcedure.TableExclusiveLock.acquireLock(MasterProcedureEnv env)
boolean	LockProcedure.TableSharedLock.acquireLock(MasterProcedureEnv env)
boolean	LockProcedure.NamespaceExclusiveLock.acquireLock(MasterProcedureEnv env)
boolean	LockProcedure.RegionExclusiveLock.acquireLock(MasterProcedureEnv env)
protected void	LockProcedure.beforeReplay(MasterProcedureEnv env) On recovery, re-execute from start to acquire the locks.
protected Procedure<MasterProcedureEnv>[]	LockProcedure.execute(MasterProcedureEnv env)
boolean	LockProcedure.holdLock(MasterProcedureEnv env)
protected void	LockProcedure.releaseLock(MasterProcedureEnv env)
void	LockProcedure.LockInterface.releaseLock(MasterProcedureEnv env)
void	LockProcedure.TableExclusiveLock.releaseLock(MasterProcedureEnv env)
void	LockProcedure.TableSharedLock.releaseLock(MasterProcedureEnv env)
void	LockProcedure.NamespaceExclusiveLock.releaseLock(MasterProcedureEnv env)
void	LockProcedure.RegionExclusiveLock.releaseLock(MasterProcedureEnv env)
protected void	LockProcedure.rollback(MasterProcedureEnv env)
protected boolean	LockProcedure.setTimeoutFailure(MasterProcedureEnv env) Re run the procedure after every timeout to write new WAL entries so we don't hold back old WALs.
void	LockProcedure.unlock(MasterProcedureEnv env)

Uses of MasterProcedureEnv in org.apache.hadoop.hbase.master.procedure

Fields in org.apache.hadoop.hbase.master.procedure declared as MasterProcedureEnv

Modifier and Type	Field and Description
private MasterProcedureEnv	RSProcedureDispatcher.procedureEnv

Fields in org.apache.hadoop.hbase.master.procedure with type parameters of type MasterProcedureEnv

Modifier and Type	Field and Description
private ProcedureExecutor<MasterProcedureEnv>	ProcedureSyncWait.ProcedureFuture.procExec

Methods in org.apache.hadoop.hbase.master.procedure that return types with arguments of type MasterProcedureEnv

Modifier and Type	Method and Description
protected ProcedureExecutor<MasterProcedureEnv>	MasterProcedureUtil.NonceProcedureRunnable.getProcedureExecutor()

Methods in org.apache.hadoop.hbase.master.procedure with parameters of type MasterProcedureEnv

Modifier and Type	Method and Description
protected boolean	DeleteTableProcedure.abort(MasterProcedureEnv env)
protected boolean	SplitWALRemoteProcedure.abort(MasterProcedureEnv env)
protected boolean	ServerCrashProcedure.abort(MasterProcedureEnv env)
protected boolean	SwitchRpcThrottleRemoteProcedure.abort(MasterProcedureEnv env)
boolean	RestoreSnapshotProcedure.abort(MasterProcedureEnv env)
protected Procedure.LockState	CreateTableProcedure.acquireLock(MasterProcedureEnv env)
protected Procedure.LockState	InitMetaProcedure.acquireLock(MasterProcedureEnv env)
protected Procedure.LockState	AbstractStateMachineNamespaceProcedure.acquireLock(MasterProcedureEnv env)
protected Procedure.LockState	AbstractStateMachineRegionProcedure.acquireLock(MasterProcedureEnv env)
protected Procedure.LockState	CreateNamespaceProcedure.acquireLock(MasterProcedureEnv env)
protected Procedure.LockState	AbstractStateMachineTableProcedure.acquireLock(MasterProcedureEnv env)
protected Procedure.LockState	ServerCrashProcedure.acquireLock(MasterProcedureEnv env)
private void	RestoreSnapshotProcedure.addRegionsToInMemoryStates(List<RegionInfo> regionInfos, MasterProcedureEnv env, int regionReplication) Add regions to in-memory states
private void	CloneSnapshotProcedure.addRegionsToMeta(MasterProcedureEnv env) Add regions to hbase:meta table.
private static void	CreateTableProcedure.addRegionsToMeta(MasterProcedureEnv env, TableDescriptor tableDescriptor, List<RegionInfo> regionInfos) Add the specified set of regions to the hbase:meta table.
private static void	ModifyTableProcedure.addRegionsToMeta(MasterProcedureEnv env, TableDescriptor tableDescriptor, List<RegionInfo> regionInfos)
protected static List<RegionInfo>	CreateTableProcedure.addTableToMeta(MasterProcedureEnv env, TableDescriptor tableDescriptor, List<RegionInfo> regions)
protected void	SplitWALProcedure.afterReplay(MasterProcedureEnv env)
private void	ServerCrashProcedure.assignRegions(MasterProcedureEnv env, List<RegionInfo> regions) Assign the regions on the crashed RS to other Rses.
private static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest	RSProcedureDispatcher.buildOpenRegionRequest(MasterProcedureEnv env, ServerName serverName, List<RSProcedureDispatcher.RegionOpenOperation> operations)
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequest.RegionOpenInfo	RSProcedureDispatcher.RegionOpenOperation.buildRegionOpenInfoRequest(MasterProcedureEnv env)
private boolean	ReopenTableRegionsProcedure.canSchedule(MasterProcedureEnv env, HRegionLocation loc)
protected static void	AbstractStateMachineTableProcedure.checkOnline(MasterProcedureEnv env, RegionInfo ri) Check region is online.
protected void	AbstractStateMachineRegionProcedure.checkTableModifiable(MasterProcedureEnv env) Check whether a table is modifiable - exists and either offline or online with config set
protected void	AbstractStateMachineTableProcedure.checkTableModifiable(MasterProcedureEnv env) Check whether a table is modifiable - exists and either offline or online with config set
private static void	DeleteTableProcedure.cleanRegionsInMeta(MasterProcedureEnv env, TableName tableName) There may be items for this table still up in hbase:meta in the case where the info:regioninfo column was empty because of some write error.
private void	ServerCrashProcedure.cleanupSplitDir(MasterProcedureEnv env)
protected void	SplitWALRemoteProcedure.complete(MasterProcedureEnv env, Throwable error)
protected abstract void	ServerRemoteProcedure.complete(MasterProcedureEnv env, Throwable error)
protected void	SwitchRpcThrottleRemoteProcedure.complete(MasterProcedureEnv env, Throwable error)
protected void	TruncateTableProcedure.completionCleanup(MasterProcedureEnv env)
protected void	InitMetaProcedure.completionCleanup(MasterProcedureEnv env)
protected void	ModifyTableProcedure.completionCleanup(MasterProcedureEnv env)
protected void	ServerRemoteProcedure.completionCleanup(MasterProcedureEnv env)
protected static void	CreateNamespaceProcedure.createDirectory(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor) Create the namespace directory
private List<RegionInfo>	CloneSnapshotProcedure.createFilesystemLayout(MasterProcedureEnv env, TableDescriptor tableDescriptor, List<RegionInfo> newRegions) Create regions in file system.
protected static List<RegionInfo>	CreateTableProcedure.createFsLayout(MasterProcedureEnv env, TableDescriptor tableDescriptor, List<RegionInfo> newRegions)
protected static List<RegionInfo>	CreateTableProcedure.createFsLayout(MasterProcedureEnv env, TableDescriptor tableDescriptor, List<RegionInfo> newRegions, CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler)
private List<RegionInfo>	CloneSnapshotProcedure.createFsLayout(MasterProcedureEnv env, TableDescriptor tableDescriptor, List<RegionInfo> newRegions, CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler) Create region layout in file system.
List<RegionInfo>	CreateTableProcedure.CreateHdfsRegions.createHdfsRegions(MasterProcedureEnv env, org.apache.hadoop.fs.Path tableRootDir, TableName tableName, List<RegionInfo> newRegions)
private Procedure[]	ServerCrashProcedure.createSplittingWalProcedures(MasterProcedureEnv env, boolean splitMeta)
protected static void	DeleteTableProcedure.deleteAssignmentState(MasterProcedureEnv env, TableName tableName)
static void	MasterDDLOperationHelper.deleteColumnFamilyFromFileSystem(MasterProcedureEnv env, TableName tableName, List<RegionInfo> regionInfoList, byte[] familyName, boolean hasMob) Remove the column family from the file system
protected static void	DeleteNamespaceProcedure.deleteDirectory(MasterProcedureEnv env, String namespaceName) Delete the namespace directories from the file system
private void	ModifyTableProcedure.deleteFromFs(MasterProcedureEnv env, TableDescriptor oldTableDescriptor, TableDescriptor newTableDescriptor) Removes from hdfs the families that are not longer present in the new table descriptor.
protected static void	DeleteTableProcedure.deleteFromFs(MasterProcedureEnv env, TableName tableName, List<RegionInfo> regions, boolean archive)
protected static void	DeleteTableProcedure.deleteFromMeta(MasterProcedureEnv env, TableName tableName, List<RegionInfo> regions)
protected static void	DeleteNamespaceProcedure.deleteFromNSTable(MasterProcedureEnv env, String namespaceName) delete the row from namespace table
private void	RestoreSnapshotProcedure.deleteRegionsFromInMemoryStates(List<RegionInfo> regionInfos, MasterProcedureEnv env, int regionReplication) Delete regions from in-memory states
protected static void	DeleteTableProcedure.deleteTableDescriptorCache(MasterProcedureEnv env, TableName tableName)
protected static void	DeleteTableProcedure.deleteTableStates(MasterProcedureEnv env, TableName tableName)
void	RSProcedureDispatcher.RemoteProcedureResolver.dispatchCloseRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionCloseOperation> operations)
void	RSProcedureDispatcher.ExecuteProceduresRemoteCall.dispatchCloseRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionCloseOperation> operations)
void	RSProcedureDispatcher.RemoteProcedureResolver.dispatchOpenRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionOpenOperation> operations)
void	RSProcedureDispatcher.ExecuteProceduresRemoteCall.dispatchOpenRequests(MasterProcedureEnv env, List<RSProcedureDispatcher.RegionOpenOperation> operations)
void	RSProcedureDispatcher.RemoteProcedureResolver.dispatchServerOperations(MasterProcedureEnv env, List<RSProcedureDispatcher.ServerOperation> operations)
void	RSProcedureDispatcher.ExecuteProceduresRemoteCall.dispatchServerOperations(MasterProcedureEnv env, List<RSProcedureDispatcher.ServerOperation> operations)
protected Procedure<MasterProcedureEnv>[]	ServerRemoteProcedure.execute(MasterProcedureEnv env)
protected StateMachineProcedure.Flow	CloneSnapshotProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.CloneSnapshotState state)
protected StateMachineProcedure.Flow	CreateNamespaceProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.CreateNamespaceState state)
protected StateMachineProcedure.Flow	CreateTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.CreateTableState state)
protected StateMachineProcedure.Flow	DeleteNamespaceProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceState state)
protected StateMachineProcedure.Flow	DeleteTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteTableState state)
protected StateMachineProcedure.Flow	DisableTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DisableTableState state)
protected StateMachineProcedure.Flow	EnableTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.EnableTableState state)
protected StateMachineProcedure.Flow	InitMetaProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.InitMetaState state)
protected StateMachineProcedure.Flow	ModifyNamespaceProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyNamespaceState state)
protected StateMachineProcedure.Flow	ModifyTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableState state)
protected StateMachineProcedure.Flow	RecoverMetaProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverMetaState state) Deprecated.
protected StateMachineProcedure.Flow	ReopenTableRegionsProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ReopenTableRegionsState state)
protected StateMachineProcedure.Flow	RestoreSnapshotProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RestoreSnapshotState state)
protected StateMachineProcedure.Flow	ServerCrashProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ServerCrashState state)
protected StateMachineProcedure.Flow	SplitWALProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitWALState state)
protected StateMachineProcedure.Flow	SwitchRpcThrottleProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SwitchRpcThrottleState state)
protected StateMachineProcedure.Flow	TruncateTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.TruncateTableState state)
protected static MasterQuotaManager	ProcedureSyncWait.getMasterQuotaManager(MasterProcedureEnv env)
protected ProcedureMetrics	ServerCrashProcedure.getProcedureMetrics(MasterProcedureEnv env)
private List<RegionInfo>	ModifyTableProcedure.getRegionInfoList(MasterProcedureEnv env) Fetches all Regions for a table.
(package private) List<RegionInfo>	HBCKServerCrashProcedure.getRegionsOnCrashedServer(MasterProcedureEnv env) If no Regions found in Master context, then we will search hbase:meta for references to the passed server.
(package private) List<RegionInfo>	ServerCrashProcedure.getRegionsOnCrashedServer(MasterProcedureEnv env)
private static TableNamespaceManager	DeleteNamespaceProcedure.getTableNamespaceManager(MasterProcedureEnv env)
private TableNamespaceManager	ModifyNamespaceProcedure.getTableNamespaceManager(MasterProcedureEnv env)
private static TableNamespaceManager	CreateNamespaceProcedure.getTableNamespaceManager(MasterProcedureEnv env)
protected org.apache.hadoop.fs.Path	AbstractStateMachineTableProcedure.getWALRegionDir(MasterProcedureEnv env, RegionInfo region)
protected boolean	TruncateTableProcedure.holdLock(MasterProcedureEnv env)
protected boolean	DeleteTableProcedure.holdLock(MasterProcedureEnv env)
protected boolean	AbstractStateMachineRegionProcedure.holdLock(MasterProcedureEnv env)
protected boolean	DisableTableProcedure.holdLock(MasterProcedureEnv env)
protected boolean	ServerCrashProcedure.holdLock(MasterProcedureEnv env)
private void	ModifyNamespaceProcedure.insertIntoNSTable(MasterProcedureEnv env) Insert/update the row into namespace table
protected static void	CreateNamespaceProcedure.insertIntoNSTable(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor) Insert the row into ns table
private boolean	ServerCrashProcedure.isSplittingDone(MasterProcedureEnv env, boolean splitMeta)
protected static void	CreateTableProcedure.moveTempDirectoryToHBaseRoot(MasterProcedureEnv env, TableDescriptor tableDescriptor, org.apache.hadoop.fs.Path tempTableDir)
private void	CloneSnapshotProcedure.postCloneSnapshot(MasterProcedureEnv env) Action after cloning from snapshot.
private void	CreateTableProcedure.postCreate(MasterProcedureEnv env)
private void	DeleteTableProcedure.postDelete(MasterProcedureEnv env)
protected void	DisableTableProcedure.postDisable(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DisableTableState state) Action after disabling table.
private void	EnableTableProcedure.postEnable(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.EnableTableState state) Action after enabling table.
private void	ModifyTableProcedure.postModify(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableState state) Action after modifying table.
private void	TruncateTableProcedure.postTruncate(MasterProcedureEnv env)
private void	CloneSnapshotProcedure.preCloneSnapshot(MasterProcedureEnv env) Action before cloning from snapshot.
private void	CreateTableProcedure.preCreate(MasterProcedureEnv env)
private boolean	DeleteTableProcedure.preDelete(MasterProcedureEnv env)
protected void	DisableTableProcedure.preDisable(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DisableTableState state) Action before disabling table.
private void	EnableTableProcedure.preEnable(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.EnableTableState state) Action before enabling table.
protected void	AbstractStateMachineTableProcedure.preflightChecks(MasterProcedureEnv env, Boolean enabled) Check that cluster is up and master is running.
private void	ModifyTableProcedure.preModify(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableState state) Action before modifying table.
private void	CloneSnapshotProcedure.prepareClone(MasterProcedureEnv env) Action before any real action of cloning from snapshot.
private boolean	CreateTableProcedure.prepareCreate(MasterProcedureEnv env)
private boolean	CreateNamespaceProcedure.prepareCreate(MasterProcedureEnv env) Action before any real action of creating namespace.
private boolean	DeleteNamespaceProcedure.prepareDelete(MasterProcedureEnv env) Action before any real action of deleting namespace.
private boolean	DeleteTableProcedure.prepareDelete(MasterProcedureEnv env)
private boolean	DisableTableProcedure.prepareDisable(MasterProcedureEnv env) Action before any real action of disabling table.
private boolean	EnableTableProcedure.prepareEnable(MasterProcedureEnv env) Action before any real action of enabling table.
private boolean	ModifyNamespaceProcedure.prepareModify(MasterProcedureEnv env) Action before any real action of adding namespace.
private void	ModifyTableProcedure.prepareModify(MasterProcedureEnv env) Check conditions before any real action of modifying a table.
private void	RestoreSnapshotProcedure.prepareRestore(MasterProcedureEnv env) Action before any real action of restoring from snapshot.
private boolean	TruncateTableProcedure.prepareTruncate(MasterProcedureEnv env)
private boolean	TruncateTableProcedure.preTruncate(MasterProcedureEnv env)
protected void	AbstractStateMachineNamespaceProcedure.releaseLock(MasterProcedureEnv env)
protected void	AbstractStateMachineRegionProcedure.releaseLock(MasterProcedureEnv env)
protected void	AbstractStateMachineTableProcedure.releaseLock(MasterProcedureEnv env)
protected void	ServerCrashProcedure.releaseLock(MasterProcedureEnv env)
Optional<RemoteProcedureDispatcher.RemoteOperation>	SplitWALRemoteProcedure.remoteCallBuild(MasterProcedureEnv env, ServerName serverName)
Optional<RemoteProcedureDispatcher.RemoteOperation>	SwitchRpcThrottleRemoteProcedure.remoteCallBuild(MasterProcedureEnv masterProcedureEnv, ServerName remote)
protected void	RSProcedureDispatcher.ExecuteProceduresRemoteCall.remoteCallFailed(MasterProcedureEnv env, IOException e)
void	ServerRemoteProcedure.remoteCallFailed(MasterProcedureEnv env, ServerName serverName, IOException exception)
void	ServerRemoteProcedure.remoteOperationCompleted(MasterProcedureEnv env)
(package private) void	ServerRemoteProcedure.remoteOperationDone(MasterProcedureEnv env, Throwable error)
void	ServerRemoteProcedure.remoteOperationFailed(MasterProcedureEnv env, RemoteProcedureException error)
protected static void	DeleteNamespaceProcedure.removeFromZKNamespaceManager(MasterProcedureEnv env, String namespaceName) remove from ZooKeeper.
protected static void	DeleteNamespaceProcedure.removeNamespaceQuota(MasterProcedureEnv env, String namespaceName) remove quota for the namespace
private void	RestoreSnapshotProcedure.restoreSnapshot(MasterProcedureEnv env) Execute the on-disk Restore
private void	CloneSnapshotProcedure.restoreSnapshotAcl(MasterProcedureEnv env)
private void	RestoreSnapshotProcedure.restoreSnapshotAcl(MasterProcedureEnv env)
protected void	SplitWALRemoteProcedure.rollback(MasterProcedureEnv env)
protected void	SwitchRpcThrottleRemoteProcedure.rollback(MasterProcedureEnv env)
private void	DeleteNamespaceProcedure.rollbackDeleteDirectory(MasterProcedureEnv env) undo delete directory
protected void	CloneSnapshotProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.CloneSnapshotState state)
protected void	CreateNamespaceProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.CreateNamespaceState state)
protected void	CreateTableProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.CreateTableState state)
protected void	DeleteNamespaceProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceState state)
protected void	DeleteTableProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteTableState state)
protected void	DisableTableProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DisableTableState state)
protected void	EnableTableProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.EnableTableState state)
protected void	InitMetaProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.InitMetaState state)
protected void	ModifyNamespaceProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyNamespaceState state)
protected void	ModifyTableProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableState state)
protected void	RecoverMetaProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverMetaState recoverMetaState) Deprecated.
protected void	ReopenTableRegionsProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ReopenTableRegionsState state)
protected void	RestoreSnapshotProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RestoreSnapshotState state)
protected void	ServerCrashProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ServerCrashState state)
protected void	SplitWALProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitWALState splitOneWalState)
protected void	SwitchRpcThrottleProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SwitchRpcThrottleState state)
protected void	TruncateTableProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.TruncateTableState state)
private void	DeleteNamespaceProcedure.rollbacRemoveNamespaceQuota(MasterProcedureEnv env) undo remove quota for the namespace
private void	DisableTableProcedure.runCoprocessorAction(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DisableTableState state) Coprocessor Action.
private void	EnableTableProcedure.runCoprocessorAction(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.EnableTableState state) Coprocessor Action.
private void	ModifyTableProcedure.runCoprocessorAction(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableState state) Coprocessor Action.
protected static void	CreateTableProcedure.setEnabledState(MasterProcedureEnv env, TableName tableName)
protected static void	CreateTableProcedure.setEnablingState(MasterProcedureEnv env, TableName tableName)
protected static void	CreateNamespaceProcedure.setNamespaceQuota(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor) Set quota for the namespace
protected static void	DisableTableProcedure.setTableStateToDisabled(MasterProcedureEnv env, TableName tableName) Mark table state to Disabled
private static void	DisableTableProcedure.setTableStateToDisabling(MasterProcedureEnv env, TableName tableName) Mark table state to Disabling
protected static void	EnableTableProcedure.setTableStateToEnabled(MasterProcedureEnv env, TableName tableName) Mark table state to Enabled
protected static void	EnableTableProcedure.setTableStateToEnabling(MasterProcedureEnv env, TableName tableName) Mark table state to Enabling
protected boolean	SplitWALProcedure.setTimeoutFailure(MasterProcedureEnv env)
protected boolean	ReopenTableRegionsProcedure.setTimeoutFailure(MasterProcedureEnv env) At end of timeout, wake ourselves up so we run again.
protected boolean	CreateTableProcedure.shouldWaitClientAck(MasterProcedureEnv env)
protected boolean	CreateNamespaceProcedure.shouldWaitClientAck(MasterProcedureEnv env)
protected boolean	ServerCrashProcedure.shouldWaitClientAck(MasterProcedureEnv env)
private void	ServerCrashProcedure.splitLogs(MasterProcedureEnv env)
private void	ServerCrashProcedure.splitMetaLogs(MasterProcedureEnv env)
void	SwitchRpcThrottleProcedure.switchThrottleState(MasterProcedureEnv env, boolean rpcThrottleEnabled)
private void	DeleteNamespaceProcedure.undoDeleteFromNSTable(MasterProcedureEnv env) undo the delete
private void	DeleteNamespaceProcedure.undoRemoveFromZKNamespaceManager(MasterProcedureEnv env) undo the remove from ZooKeeper
private void	RestoreSnapshotProcedure.updateMETA(MasterProcedureEnv env) Apply changes to hbase:meta
static void	ServerCrashProcedure.updateProgress(MasterProcedureEnv env, long parentId)
private void	ModifyTableProcedure.updateReplicaColumnsIfNeeded(MasterProcedureEnv env, TableDescriptor oldTableDescriptor, TableDescriptor newTableDescriptor) update replica column families if necessary.
protected static void	CreateTableProcedure.updateTableDescCache(MasterProcedureEnv env, TableName tableName)
private void	ModifyTableProcedure.updateTableDescriptor(MasterProcedureEnv env) Update descriptor
private void	RestoreSnapshotProcedure.updateTableDescriptor(MasterProcedureEnv env) Update descriptor
private void	ModifyNamespaceProcedure.updateZKNamespaceManager(MasterProcedureEnv env) Update ZooKeeper.
protected static void	CreateNamespaceProcedure.updateZKNamespaceManager(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor) Update ZooKeeper.
static <T> T	ProcedureSyncWait.waitFor(MasterProcedureEnv env, long waitTime, long waitingTimeForEvents, String purpose, ProcedureSyncWait.Predicate<T> predicate)
static <T> T	ProcedureSyncWait.waitFor(MasterProcedureEnv env, long waitTime, String purpose, ProcedureSyncWait.Predicate<T> predicate)
static <T> T	ProcedureSyncWait.waitFor(MasterProcedureEnv env, String purpose, ProcedureSyncWait.Predicate<T> predicate)
protected boolean	CreateTableProcedure.waitInitialized(MasterProcedureEnv env)
protected boolean	InitMetaProcedure.waitInitialized(MasterProcedureEnv env)
protected boolean	AbstractStateMachineNamespaceProcedure.waitInitialized(MasterProcedureEnv env)
protected boolean	CreateNamespaceProcedure.waitInitialized(MasterProcedureEnv env)
protected boolean	AbstractStateMachineTableProcedure.waitInitialized(MasterProcedureEnv env)
protected static void	ProcedureSyncWait.waitMetaRegions(MasterProcedureEnv env)
protected static void	ProcedureSyncWait.waitRegionInTransition(MasterProcedureEnv env, List<RegionInfo> regions)

Method parameters in org.apache.hadoop.hbase.master.procedure with type arguments of type MasterProcedureEnv

Modifier and Type	Method and Description
static byte[]	ProcedureSyncWait.submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<MasterProcedureEnv> proc)
static byte[]	ProcedureSyncWait.submitAndWaitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<MasterProcedureEnv> proc)
protected long	MasterProcedureUtil.NonceProcedureRunnable.submitProcedure(Procedure<MasterProcedureEnv> proc)
static Future<byte[]>	ProcedureSyncWait.submitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<MasterProcedureEnv> proc)
static Future<byte[]>	ProcedureSyncWait.submitProcedure(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<MasterProcedureEnv> proc)
static byte[]	ProcedureSyncWait.waitForProcedureToComplete(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc, long timeout)
static byte[]	ProcedureSyncWait.waitForProcedureToCompleteIOE(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc, long timeout)

Constructors in org.apache.hadoop.hbase.master.procedure with parameters of type MasterProcedureEnv

Constructor and Description
AbstractStateMachineNamespaceProcedure(MasterProcedureEnv env)
AbstractStateMachineNamespaceProcedure(MasterProcedureEnv env, ProcedurePrepareLatch latch)
AbstractStateMachineRegionProcedure(MasterProcedureEnv env, RegionInfo hri)
AbstractStateMachineTableProcedure(MasterProcedureEnv env)
AbstractStateMachineTableProcedure(MasterProcedureEnv env, ProcedurePrepareLatch latch)
CloneSnapshotProcedure(MasterProcedureEnv env, TableDescriptor tableDescriptor, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot)
CloneSnapshotProcedure(MasterProcedureEnv env, TableDescriptor tableDescriptor, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot, boolean restoreAcl) Constructor
CreateNamespaceProcedure(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor)
CreateNamespaceProcedure(MasterProcedureEnv env, NamespaceDescriptor nsDescriptor, ProcedurePrepareLatch latch)
CreateTableProcedure(MasterProcedureEnv env, TableDescriptor tableDescriptor, RegionInfo[] newRegions)
CreateTableProcedure(MasterProcedureEnv env, TableDescriptor tableDescriptor, RegionInfo[] newRegions, ProcedurePrepareLatch syncLatch)
DeleteNamespaceProcedure(MasterProcedureEnv env, String namespaceName)
DeleteNamespaceProcedure(MasterProcedureEnv env, String namespaceName, ProcedurePrepareLatch latch)
DeleteTableProcedure(MasterProcedureEnv env, TableName tableName)
DeleteTableProcedure(MasterProcedureEnv env, TableName tableName, ProcedurePrepareLatch syncLatch)
DisableTableProcedure(MasterProcedureEnv env, TableName tableName, boolean skipTableStateCheck) Constructor
DisableTableProcedure(MasterProcedureEnv env, TableName tableName, boolean skipTableStateCheck, ProcedurePrepareLatch syncLatch) Constructor
EnableTableProcedure(MasterProcedureEnv env, TableName tableName) Constructor
EnableTableProcedure(MasterProcedureEnv env, TableName tableName, ProcedurePrepareLatch syncLatch) Constructor
HBCKServerCrashProcedure(MasterProcedureEnv env, ServerName serverName, boolean shouldSplitWal, boolean carryingMeta)
ModifyNamespaceProcedure(MasterProcedureEnv env, NamespaceDescriptor newNsDescriptor)
ModifyNamespaceProcedure(MasterProcedureEnv env, NamespaceDescriptor newNsDescriptor, ProcedurePrepareLatch latch)
ModifyTableProcedure(MasterProcedureEnv env, TableDescriptor htd)
ModifyTableProcedure(MasterProcedureEnv env, TableDescriptor htd, ProcedurePrepareLatch latch)
ModifyTableProcedure(MasterProcedureEnv env, TableDescriptor newTableDescriptor, ProcedurePrepareLatch latch, TableDescriptor oldTableDescriptor, boolean shouldCheckDescriptor)
RestoreSnapshotProcedure(MasterProcedureEnv env, TableDescriptor tableDescriptor, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot)
RestoreSnapshotProcedure(MasterProcedureEnv env, TableDescriptor tableDescriptor, org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription snapshot, boolean restoreAcl) Constructor
ServerCrashProcedure(MasterProcedureEnv env, ServerName serverName, boolean shouldSplitWal, boolean carryingMeta) Call this constructor queuing up a Procedure.
TruncateTableProcedure(MasterProcedureEnv env, TableName tableName, boolean preserveSplits)
TruncateTableProcedure(MasterProcedureEnv env, TableName tableName, boolean preserveSplits, ProcedurePrepareLatch latch)

Constructor parameters in org.apache.hadoop.hbase.master.procedure with type arguments of type MasterProcedureEnv

Constructor and Description
ProcedureFuture(ProcedureExecutor<MasterProcedureEnv> procExec, Procedure<?> proc)

Uses of MasterProcedureEnv in org.apache.hadoop.hbase.master.replication

Methods in org.apache.hadoop.hbase.master.replication with parameters of type MasterProcedureEnv

Modifier and Type	Method and Description
protected boolean	RefreshPeerProcedure.abort(MasterProcedureEnv env)
protected Procedure.LockState	AbstractPeerProcedure.acquireLock(MasterProcedureEnv env)
protected void	RefreshPeerProcedure.complete(MasterProcedureEnv env, Throwable error)
protected void	ModifyPeerProcedure.enablePeer(MasterProcedureEnv env)
protected StateMachineProcedure.Flow	ModifyPeerProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state)
protected boolean	AbstractPeerProcedure.holdLock(MasterProcedureEnv env)
protected void	EnablePeerProcedure.postPeerModification(MasterProcedureEnv env)
protected abstract void	ModifyPeerProcedure.postPeerModification(MasterProcedureEnv env) Called before we finish the procedure.
protected void	UpdatePeerConfigProcedure.postPeerModification(MasterProcedureEnv env)
protected void	RemovePeerProcedure.postPeerModification(MasterProcedureEnv env)
protected void	AddPeerProcedure.postPeerModification(MasterProcedureEnv env)
protected void	DisablePeerProcedure.postPeerModification(MasterProcedureEnv env)
protected void	EnablePeerProcedure.prePeerModification(MasterProcedureEnv env)
protected abstract void	ModifyPeerProcedure.prePeerModification(MasterProcedureEnv env) Called before we start the actual processing.
protected void	UpdatePeerConfigProcedure.prePeerModification(MasterProcedureEnv env)
protected void	RemovePeerProcedure.prePeerModification(MasterProcedureEnv env)
protected void	AddPeerProcedure.prePeerModification(MasterProcedureEnv env)
protected void	DisablePeerProcedure.prePeerModification(MasterProcedureEnv env)
private void	ModifyPeerProcedure.refreshPeer(MasterProcedureEnv env, PeerProcedureInterface.PeerOperationType type)
protected void	AbstractPeerProcedure.releaseLock(MasterProcedureEnv env)
Optional<RemoteProcedureDispatcher.RemoteOperation>	RefreshPeerProcedure.remoteCallBuild(MasterProcedureEnv env, ServerName remote)
protected void	ModifyPeerProcedure.reopenRegions(MasterProcedureEnv env)
protected void	RefreshPeerProcedure.rollback(MasterProcedureEnv env)
protected void	ModifyPeerProcedure.rollbackState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state)
protected void	ModifyPeerProcedure.setLastPushedSequenceId(MasterProcedureEnv env, ReplicationPeerConfig peerConfig)
protected void	ModifyPeerProcedure.setLastPushedSequenceIdForTable(MasterProcedureEnv env, TableName tableName, Map<String,Long> lastSeqIds)
protected boolean	ModifyPeerProcedure.setTimeoutFailure(MasterProcedureEnv env)
protected void	ModifyPeerProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env)
protected void	UpdatePeerConfigProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env)
protected void	AddPeerProcedure.updateLastPushedSequenceIdForSerialPeer(MasterProcedureEnv env)
protected void	EnablePeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected abstract void	ModifyPeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected void	UpdatePeerConfigProcedure.updatePeerStorage(MasterProcedureEnv env)
protected void	RemovePeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected void	AddPeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected void	DisablePeerProcedure.updatePeerStorage(MasterProcedureEnv env)
protected boolean	AbstractPeerProcedure.waitInitialized(MasterProcedureEnv env)
protected boolean	RefreshPeerProcedure.waitInitialized(MasterProcedureEnv env)