| Modifier and Type | Field and Description |
|---|---|
private ProcedureExecutor<MasterProcedureEnv> |
HMaster.procedureExecutor |
| Modifier and Type | Method and Description |
|---|---|
ProcedureExecutor<MasterProcedureEnv> |
MasterServices.getMasterProcedureExecutor()
Returns Master's instance of
ProcedureExecutor |
ProcedureExecutor<MasterProcedureEnv> |
HMaster.getMasterProcedureExecutor() |
private RemoteProcedureDispatcher.RemoteProcedure<MasterProcedureEnv,?> |
HMaster.getRemoteProcedure(long procId) |
| Modifier and Type | Method and Description |
|---|---|
void |
MasterCoprocessorHost.preAbortProcedure(ProcedureExecutor<MasterProcedureEnv> procEnv,
long procId) |
private long |
ClusterSchemaServiceImpl.submitProcedure(Procedure<MasterProcedureEnv> procedure,
NonceKey nonceKey) |
| Modifier and Type | Method and Description |
|---|---|
private MasterProcedureEnv |
AssignmentManager.getProcedureEnvironment() |
| 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 Procedure.LockState |
GCMultipleMergedRegionsProcedure.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)
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) |
(package private) static TransitRegionStateProcedure[] |
AssignmentManagerUtil.createAssignProceduresForSplitDaughters(MasterProcedureEnv env,
List<RegionInfo> daughters,
int regionReplication,
ServerName parentServer) |
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 static TransitRegionStateProcedure[] |
AssignmentManagerUtil.createRoundRobinAssignProcedures(MasterProcedureEnv env,
List<RegionInfo> regions,
int regionReplication,
List<ServerName> serversToExclude,
boolean ignoreIfInTransition)
Create round robin assign procedures for the given regions, according to the
regionReplication. |
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) |
private void |
SplitTableRegionProcedure.deleteDaughterRegions(MasterProcedureEnv env) |
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) |
protected boolean |
GCMultipleMergedRegionsProcedure.holdLock(MasterProcedureEnv env) |
private boolean |
MergeTableRegionsProcedure.isMergeable(MasterProcedureEnv env,
RegionState rs) |
private List<org.apache.hadoop.fs.Path> |
MergeTableRegionsProcedure.mergeStoreFiles(MasterProcedureEnv env,
HRegionFileSystem regionFs,
HRegionFileSystem mergeRegionFs,
RegionInfo mergedRegion) |
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) |
protected void |
GCMultipleMergedRegionsProcedure.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.
Returns If true, we will re-wake up this procedure; if false, the procedure stays suspended.
|
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)
. |
(package private) void |
RegionRemoteProcedureBase.serverCrashed(MasterProcedureEnv env,
RegionStateNode regionNode,
ServerName serverName) |
void |
TransitRegionStateProcedure.serverCrashed(MasterProcedureEnv env,
RegionStateNode regionNode,
ServerName serverName,
boolean forceNewPlan) |
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<List<org.apache.hadoop.fs.Path>,List<org.apache.hadoop.fs.Path>> |
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) |
| 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) |
| 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) |
| Modifier and Type | Field and Description |
|---|---|
(package private) ProcedureExecutor<MasterProcedureEnv> |
RollingUpgradeChore.procedureExecutor |
| Constructor and Description |
|---|
RollingUpgradeChore(org.apache.hadoop.conf.Configuration conf,
ProcedureExecutor<MasterProcedureEnv> procedureExecutor,
TableDescriptors tableDescriptors,
Stoppable stopper) |
| Modifier and Type | Field and Description |
|---|---|
private MasterProcedureEnv |
RSProcedureDispatcher.procedureEnv |
| Modifier and Type | Field and Description |
|---|---|
private ProcedureExecutor<MasterProcedureEnv> |
ProcedureSyncWait.ProcedureFuture.procExec |
| Modifier and Type | Method and Description |
|---|---|
protected ProcedureExecutor<MasterProcedureEnv> |
MasterProcedureUtil.NonceProcedureRunnable.getProcedureExecutor() |
| 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 |
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.
|
protected static List<RegionInfo> |
CreateTableProcedure.addTableToMeta(MasterProcedureEnv env,
TableDescriptor tableDescriptor,
List<RegionInfo> regions) |
protected void |
SplitWALProcedure.afterReplay(MasterProcedureEnv env) |
private void |
ModifyTableProcedure.assignNewReplicasIfNeeded(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 |
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) |
private void |
ModifyTableProcedure.closeExcessReplicasIfNeeded(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 |
ModifyTableDescriptorProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableDescriptorState 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)
Returns List of Regions on crashed server.
|
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 |
ModifyTableDescriptorProcedure.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 boolean |
AbstractStateMachineTableProcedure.isTableEnabled(MasterProcedureEnv env) |
protected abstract Optional<TableDescriptor> |
ModifyTableDescriptorProcedure.modify(MasterProcedureEnv env,
TableDescriptor current)
Sub class should implement this method to modify the table descriptor, such as storing the rs
group information.
|
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 |
ModifyTableProcedure.preflightChecks(MasterProcedureEnv env,
Boolean enabled) |
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 |
ModifyTableProcedure.removeReplicaColumnsIfNeeded(MasterProcedureEnv env)
remove replica columns if necessary.
|
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 |
ModifyTableDescriptorProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableDescriptorState 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) |
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.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) |
private void |
ServerCrashProcedure.zkCoordinatedSplitLogs(MasterProcedureEnv env)
Split logs using 'classic' zk-based coordination.
|
private void |
ServerCrashProcedure.zkCoordinatedSplitMetaLogs(MasterProcedureEnv env)
Split hbase:meta logs using 'classic' zk-based coordination.
|
| Constructor and Description |
|---|
ProcedureFuture(ProcedureExecutor<MasterProcedureEnv> procExec,
Procedure<?> proc) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
ClaimReplicationQueueRemoteProcedure.abort(MasterProcedureEnv env) |
protected boolean |
ClaimReplicationQueuesProcedure.abort(MasterProcedureEnv env) |
protected boolean |
RefreshPeerProcedure.abort(MasterProcedureEnv env) |
protected Procedure.LockState |
AbstractPeerProcedure.acquireLock(MasterProcedureEnv env) |
protected void |
ClaimReplicationQueueRemoteProcedure.complete(MasterProcedureEnv env,
Throwable error) |
protected void |
RefreshPeerProcedure.complete(MasterProcedureEnv env,
Throwable error) |
protected void |
ModifyPeerProcedure.enablePeer(MasterProcedureEnv env) |
protected Procedure<MasterProcedureEnv>[] |
ClaimReplicationQueuesProcedure.execute(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> |
ClaimReplicationQueueRemoteProcedure.remoteCallBuild(MasterProcedureEnv env,
ServerName remote) |
Optional<RemoteProcedureDispatcher.RemoteOperation> |
RefreshPeerProcedure.remoteCallBuild(MasterProcedureEnv env,
ServerName remote) |
protected void |
ModifyPeerProcedure.reopenRegions(MasterProcedureEnv env) |
protected void |
ClaimReplicationQueueRemoteProcedure.rollback(MasterProcedureEnv env) |
protected void |
ClaimReplicationQueuesProcedure.rollback(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 boolean |
ClaimReplicationQueuesProcedure.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 |
ClaimReplicationQueueRemoteProcedure.waitInitialized(MasterProcedureEnv env) |
protected boolean |
RefreshPeerProcedure.waitInitialized(MasterProcedureEnv env) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.hadoop.fs.Path |
HRegionFileSystem.commitDaughterRegion(RegionInfo regionInfo,
List<org.apache.hadoop.fs.Path> allRegionFiles,
MasterProcedureEnv env)
Commit a daughter region, moving it from the split temporary directory to the proper location
in the filesystem.
|
void |
HRegionFileSystem.commitMergedRegion(List<org.apache.hadoop.fs.Path> allMergedFiles,
MasterProcedureEnv env)
Commit a merged region, making it ready for use.
|
private void |
HRegionFileSystem.insertRegionFilesIntoStoreTracker(List<org.apache.hadoop.fs.Path> allFiles,
MasterProcedureEnv env,
HRegionFileSystem regionFs) |
| Modifier and Type | Method and Description |
|---|---|
protected StateMachineProcedure.Flow |
ModifyStoreFileTrackerProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyStoreFileTrackerState state) |
private void |
ModifyStoreFileTrackerProcedure.finish(MasterProcedureEnv env) |
private void |
ModifyStoreFileTrackerProcedure.migrate(MasterProcedureEnv env) |
protected Optional<TableDescriptor> |
InitializeStoreFileTrackerProcedure.modify(MasterProcedureEnv env,
TableDescriptor current) |
private StateMachineProcedure.Flow |
ModifyStoreFileTrackerProcedure.preCheckAndTryRestoreSFT(MasterProcedureEnv env) |
protected void |
ModifyStoreFileTrackerProcedure.rollbackState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyStoreFileTrackerState state) |
| Constructor and Description |
|---|
InitializeStoreFileTrackerProcedure(MasterProcedureEnv env,
TableName tableName) |
ModifyColumnFamilyStoreFileTrackerProcedure(MasterProcedureEnv env,
TableName tableName,
byte[] family,
String dstSFT) |
ModifyStoreFileTrackerProcedure(MasterProcedureEnv env,
TableName tableName,
String dstSFT) |
ModifyTableStoreFileTrackerProcedure(MasterProcedureEnv env,
TableName tableName,
String dstSFT) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.