| 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 |
| Modifier and Type | Field and Description |
|---|---|
private ProcedureExecutor<MasterProcedureEnv> |
HMaster.procedureExecutor |
| Modifier and Type | Method and Description |
|---|---|
ProcedureExecutor<MasterProcedureEnv> |
MasterServices.getMasterProcedureExecutor() |
ProcedureExecutor<MasterProcedureEnv> |
HMaster.getMasterProcedureExecutor() |
| 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) |
boolean |
MoveRegionProcedure.abort(MasterProcedureEnv env) |
protected boolean |
RegionTransitionProcedure.abort(MasterProcedureEnv env) |
protected Procedure.LockState |
MergeTableRegionsProcedure.acquireLock(MasterProcedureEnv env) |
protected Procedure.LockState |
RegionTransitionProcedure.acquireLock(MasterProcedureEnv env) |
protected boolean |
RegionTransitionProcedure.addToRemoteDispatcher(MasterProcedureEnv env,
ServerName targetServer)
Be careful! At the end of this method, the procedure has either succeeded
and this procedure has been set into a suspended state OR, we failed and
this procedure has been put back on the scheduler ready for another worker
to pick it up.
|
protected void |
RegionTransitionProcedure.bypass(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 AssignProcedure[] |
SplitTableRegionProcedure.createAssignProcedures(MasterProcedureEnv env,
int regionReplication) |
private AssignProcedure[] |
MergeTableRegionsProcedure.createAssignProcedures(MasterProcedureEnv env,
int regionReplication) |
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 UnassignProcedure[] |
SplitTableRegionProcedure.createUnassignProcedures(MasterProcedureEnv env,
int regionReplication) |
private UnassignProcedure[] |
MergeTableRegionsProcedure.createUnassignProcedures(MasterProcedureEnv env,
int regionReplication) |
protected Procedure[] |
RegionTransitionProcedure.execute(MasterProcedureEnv env) |
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) |
protected StateMachineProcedure.Flow |
SplitTableRegionProcedure.executeFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitTableRegionState state) |
protected void |
UnassignProcedure.finishTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected void |
AssignProcedure.finishTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected abstract void |
RegionTransitionProcedure.finishTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
private ServerName |
SplitTableRegionProcedure.getParentRegionServerName(MasterProcedureEnv env) |
protected ProcedureMetrics |
UnassignProcedure.getProcedureMetrics(MasterProcedureEnv env) |
protected ProcedureMetrics |
SplitTableRegionProcedure.getProcedureMetrics(MasterProcedureEnv env) |
protected ProcedureMetrics |
MergeTableRegionsProcedure.getProcedureMetrics(MasterProcedureEnv env) |
protected ProcedureMetrics |
AssignProcedure.getProcedureMetrics(MasterProcedureEnv env) |
(package private) static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse |
Util.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 |
Util.getRegionInfoResponse(MasterProcedureEnv env,
ServerName regionLocation,
RegionInfo hri,
boolean includeBestSplitRow) |
private int |
SplitTableRegionProcedure.getRegionReplication(MasterProcedureEnv env) |
private int |
MergeTableRegionsProcedure.getRegionReplication(MasterProcedureEnv env) |
RegionStates.RegionStateNode |
RegionTransitionProcedure.getRegionState(MasterProcedureEnv env) |
ServerName |
UnassignProcedure.getServer(MasterProcedureEnv env) |
ServerName |
AssignProcedure.getServer(MasterProcedureEnv env) |
abstract ServerName |
RegionTransitionProcedure.getServer(MasterProcedureEnv env)
Used by ServerCrashProcedure to see if this Assign/Unassign needs processing.
|
private ServerName |
MergeTableRegionsProcedure.getServerName(MasterProcedureEnv env)
The procedure could be restarted from a different machine.
|
private void |
AssignProcedure.handleFailure(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode)
Called when dispatch or subsequent OPEN request fail.
|
private List<RegionInfo> |
MergeTableRegionsProcedure.hasRecoveredEdits(MasterProcedureEnv env)
Return list of regions that have recovered.edits...
|
(package private) static boolean |
SplitTableRegionProcedure.hasRecoveredEdits(MasterProcedureEnv env,
RegionInfo ri)
Check whether there are recovered.edits in the parent closed region.
|
protected boolean |
MergeTableRegionsProcedure.holdLock(MasterProcedureEnv env) |
protected boolean |
RegionTransitionProcedure.holdLock(MasterProcedureEnv env) |
private boolean |
AssignProcedure.incrementAndCheckMaxAttempts(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
private boolean |
MergeTableRegionsProcedure.isMergeable(MasterProcedureEnv env,
RegionState rs) |
private boolean |
UnassignProcedure.isSafeToProceed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
IOException exception)
Our remote call failed but there are a few states where it is safe to proceed with the
unassign; e.g.
|
protected boolean |
RegionTransitionProcedure.isServerOnline(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected boolean |
RegionTransitionProcedure.isServerOnline(MasterProcedureEnv env,
ServerName serverName) |
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 |
private void |
SplitTableRegionProcedure.openParentRegion(MasterProcedureEnv env)
Rollback close parent region
|
protected void |
AssignmentManager.RegionInTransitionChore.periodicExecute(MasterProcedureEnv env) |
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
|
protected void |
UnassignProcedure.proceed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode)
Set it up so when procedure is unsuspended, we'll move to the procedure finish.
|
protected void |
MergeTableRegionsProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
RegionTransitionProcedure.releaseLock(MasterProcedureEnv env) |
RemoteProcedureDispatcher.RemoteOperation |
UnassignProcedure.remoteCallBuild(MasterProcedureEnv env,
ServerName serverName) |
RemoteProcedureDispatcher.RemoteOperation |
AssignProcedure.remoteCallBuild(MasterProcedureEnv env,
ServerName serverName) |
abstract RemoteProcedureDispatcher.RemoteOperation |
RegionTransitionProcedure.remoteCallBuild(MasterProcedureEnv env,
ServerName serverName) |
void |
RegionTransitionProcedure.remoteCallCompleted(MasterProcedureEnv env,
ServerName serverName,
RemoteProcedureDispatcher.RemoteOperation response) |
protected boolean |
UnassignProcedure.remoteCallFailed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
IOException exception) |
protected boolean |
AssignProcedure.remoteCallFailed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
IOException exception) |
protected abstract boolean |
RegionTransitionProcedure.remoteCallFailed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
IOException exception) |
boolean |
RegionTransitionProcedure.remoteCallFailed(MasterProcedureEnv env,
ServerName serverName,
IOException exception) |
protected void |
UnassignProcedure.reportTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long seqId) |
protected void |
AssignProcedure.reportTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long openSeqNum) |
protected abstract void |
RegionTransitionProcedure.reportTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long seqId) |
protected void |
RegionTransitionProcedure.reportTransition(MasterProcedureEnv env,
ServerName serverName,
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionStateTransition.TransitionCode code,
long seqId) |
protected void |
RegionTransitionProcedure.rollback(MasterProcedureEnv env) |
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) |
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 |
MergeTableRegionsProcedure.setRegionStateToMerging(MasterProcedureEnv env)
Set the region states to MERGING state
|
protected boolean |
RegionTransitionProcedure.setTimeoutFailure(MasterProcedureEnv env)
At end of timeout, wake ourselves up so we run again.
|
protected boolean |
RegionTransitionProcedure.shouldWaitClientAck(MasterProcedureEnv env) |
private Pair<Integer,Integer> |
SplitTableRegionProcedure.splitStoreFiles(MasterProcedureEnv env,
HRegionFileSystem regionFs)
Create Split directory
|
protected boolean |
UnassignProcedure.startTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected boolean |
AssignProcedure.startTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected abstract boolean |
RegionTransitionProcedure.startTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
private void |
SplitTableRegionProcedure.updateMetaForDaughterRegions(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,
RegionStates.RegionStateNode regionNode) |
protected boolean |
AssignProcedure.updateTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected abstract boolean |
RegionTransitionProcedure.updateTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode)
Called when the Procedure is in the REGION_TRANSITION_DISPATCH state.
|
protected boolean |
MoveRegionProcedure.waitInitialized(MasterProcedureEnv env) |
protected boolean |
RegionTransitionProcedure.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) |
MoveRegionProcedure(MasterProcedureEnv env,
RegionPlan plan,
boolean check) |
SplitTableRegionProcedure(MasterProcedureEnv env,
RegionInfo regionToSplit,
byte[] splitRow) |
| 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 |
|---|---|
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 |
ServerCrashProcedure.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 |
RecoverMetaProcedure.acquireLock(MasterProcedureEnv env)
Deprecated.
|
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 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) |
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.
|
protected void |
TruncateTableProcedure.completionCleanup(MasterProcedureEnv env) |
protected void |
InitMetaProcedure.completionCleanup(MasterProcedureEnv env) |
protected void |
ModifyTableProcedure.completionCleanup(MasterProcedureEnv env) |
protected void |
RecoverMetaProcedure.completionCleanup(MasterProcedureEnv env)
Deprecated.
|
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 MoveRegionProcedure |
ReopenTableRegionsProcedure.createReopenProcedure(MasterProcedureEnv env,
HRegionLocation loc) |
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) |
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 |
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) |
protected org.apache.hadoop.fs.Path |
AbstractStateMachineTableProcedure.getRegionDir(MasterProcedureEnv env,
RegionInfo region) |
private List<RegionInfo> |
ModifyTableProcedure.getRegionInfoList(MasterProcedureEnv env)
Fetches all Regions for a table.
|
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) |
private List<RegionInfo> |
ServerCrashProcedure.handleRIT(MasterProcedureEnv env,
List<RegionInfo> regions)
Handle any outstanding RIT that are up against this.serverName, the crashed server.
|
private void |
RecoverMetaProcedure.handleRIT(MasterProcedureEnv env,
RegionInfo ri,
ServerName crashedServerName)
Deprecated.
Is the region stuck assigning to this failedMetaServer? If so, cancel the call
just as we do over in ServerCrashProcedure#handleRIT except less to do here; less context
to carry.
|
protected boolean |
AbstractStateMachineRegionProcedure.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
|
protected boolean |
ServerCrashProcedure.isYieldBeforeExecuteFromState(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ServerCrashState state)
For this procedure, yield at end of each successful flow step so that all crashed servers
can make progress rather than do the default which has each procedure running to completion
before we move to the next.
|
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 |
RecoverMetaProcedure.prepare(MasterProcedureEnv env)
Deprecated.
Prepare for execution
|
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) |
private void |
ServerCrashProcedure.processMeta(MasterProcedureEnv env) |
protected void |
AbstractStateMachineNamespaceProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
AbstractStateMachineRegionProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
RecoverMetaProcedure.releaseLock(MasterProcedureEnv env)
Deprecated.
|
protected void |
AbstractStateMachineTableProcedure.releaseLock(MasterProcedureEnv env) |
protected void |
ServerCrashProcedure.releaseLock(MasterProcedureEnv env) |
private void |
RSProcedureDispatcher.CloseRegionRemoteCall.remoteCallCompleted(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse response) |
private void |
RSProcedureDispatcher.ExecuteProceduresRemoteCall.remoteCallCompleted(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse response) |
private void |
RSProcedureDispatcher.OpenRegionRemoteCall.remoteCallCompleted(MasterProcedureEnv env,
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse response) |
protected void |
RSProcedureDispatcher.ExecuteProceduresRemoteCall.remoteCallFailed(MasterProcedureEnv env,
IOException e) |
private void |
RSProcedureDispatcher.OpenRegionRemoteCall.remoteCallFailed(MasterProcedureEnv env,
IOException e) |
private void |
RSProcedureDispatcher.CloseRegionRemoteCall.remoteCallFailed(MasterProcedureEnv env,
IOException e) |
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) |
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 |
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
|
protected 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 |
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) |
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
|
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,
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) |
| Constructor and Description |
|---|
ProcedureFuture(ProcedureExecutor<MasterProcedureEnv> procExec,
Procedure<?> proc) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.