Uses of Class
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
Package
Description
-
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master
Modifier and TypeMethodDescriptionSplitWALManager.acquireSplitWALWorker
(Procedure<?> procedure) Acquire a split WAL worker -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.assignment
Modifier and TypeMethodDescriptionvoid
RegionStateNodeLock.QueueEntry.await()
Called when we can not hold the lock and should wait.private void
TransitRegionStateProcedure.checkAndWaitForOriginalServer
(MasterProcedureEnv env, ServerName lastHost) private void
TransitRegionStateProcedure.closeRegion
(MasterProcedureEnv env, RegionStateNode regionNode) private StateMachineProcedure.Flow
TransitRegionStateProcedure.confirmOpened
(MasterProcedureEnv env, RegionStateNode regionNode) protected Procedure<MasterProcedureEnv>[]
RegionRemoteProcedureBase.execute
(MasterProcedureEnv env) protected Procedure[]
TransitRegionStateProcedure.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
TransitRegionStateProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RegionStateTransitionState state) protected abstract void
RegionTransitionProcedure.finishTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.void
(package private) void
Lock by a procedure.private void
RegionStateNodeLock.lock0
(RegionStateNodeLock.QueueEntry entry) private void
TransitRegionStateProcedure.openRegion
(MasterProcedureEnv env, RegionStateNode regionNode) private void
TransitRegionStateProcedure.queueAssign
(MasterProcedureEnv env, RegionStateNode regionNode) protected abstract boolean
RegionTransitionProcedure.startTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected boolean
AssignProcedure.updateTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected abstract boolean
RegionTransitionProcedure.updateTransition
(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated. -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.locking
Modifier and TypeMethodDescriptionprotected Procedure<MasterProcedureEnv>[]
LockProcedure.execute
(MasterProcedureEnv env) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.procedure
Modifier and TypeMethodDescriptionprivate void
ServerCrashProcedure.assignRegions
(MasterProcedureEnv env, List<RegionInfo> regions) Assign the regions on the crashed RS to other Rses.protected Procedure<MasterProcedureEnv>[]
FlushRegionProcedure.execute
(MasterProcedureEnv env) protected Procedure<MasterProcedureEnv>[]
ServerRemoteProcedure.execute
(MasterProcedureEnv env) protected Procedure<MasterProcedureEnv>[]
SnapshotRegionProcedure.execute
(MasterProcedureEnv env) protected Procedure<MasterProcedureEnv>[]
SnapshotVerifyProcedure.execute
(MasterProcedureEnv env) protected StateMachineProcedure.Flow
AbstractCloseTableRegionsProcedure.executeFromState
(MasterProcedureEnv env, TState state) protected StateMachineProcedure.Flow
CreateTableProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.CreateTableState state) protected StateMachineProcedure.Flow
DeleteTableProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteTableState state) protected StateMachineProcedure.Flow
FlushTableProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.FlushTableState state) protected StateMachineProcedure.Flow
InitMetaProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.InitMetaState state) protected StateMachineProcedure.Flow
MigrateNamespaceTableProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MigrateNamespaceTableProcedureState state) protected StateMachineProcedure.Flow
ModifyTableDescriptorProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableDescriptorState 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
ServerCrashProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ServerCrashState state) protected StateMachineProcedure.Flow
SnapshotProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SnapshotState 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) private void
SnapshotProcedure.prepareSnapshot
(MasterProcedureEnv env) private StateMachineProcedure.Flow
ReopenTableRegionsProcedure.reopenIfSchedulable
(MasterProcedureEnv env, List<HRegionLocation> regionsToReopen, boolean shouldBatchBackoff) private StateMachineProcedure.Flow
AbstractCloseTableRegionsProcedure.schedule
(MasterProcedureEnv env) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.replication
Modifier and TypeMethodDescriptionprotected final ProcedureSuspendedException
AbstractPeerNoLockProcedure.suspend
(org.apache.hadoop.conf.Configuration conf, LongConsumer backoffConsumer) private ProcedureSuspendedException
MigrateReplicationQueueFromZkToTableProcedure.suspend
(org.apache.hadoop.conf.Configuration conf, LongConsumer backoffConsumer) Modifier and TypeMethodDescriptionSyncReplicationReplayWALManager.acquirePeerWorker
(String peerId, Procedure<?> proc) Get a worker for replaying remote wal for a give peer.private void
RemovePeerProcedure.checkAssignReplicationQueuesFinished
(MasterProcedureEnv env) private void
MigrateReplicationQueueFromZkToTableProcedure.disableReplicationLogCleaner
(MasterProcedureEnv env) protected Procedure<MasterProcedureEnv>[]
ClaimReplicationQueueRemoteProcedure.execute
(MasterProcedureEnv env) protected Procedure<MasterProcedureEnv>[]
ClaimReplicationQueuesProcedure.execute
(MasterProcedureEnv env) Deprecated.protected StateMachineProcedure.Flow
AssignReplicationQueuesProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.AssignReplicationQueuesState state) protected StateMachineProcedure.Flow
MigrateReplicationQueueFromZkToTableProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MigrateReplicationQueueFromZkToTableState state) protected StateMachineProcedure.Flow
ModifyPeerProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state) protected StateMachineProcedure.Flow
RecoverStandbyProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverStandbyState state) protected StateMachineProcedure.Flow
SyncReplicationReplayWALProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SyncReplicationReplayWALState state) protected StateMachineProcedure.Flow
TransitPeerSyncReplicationStateProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState state) protected abstract void
ModifyPeerProcedure.postPeerModification
(MasterProcedureEnv env) Called before we finish the procedure.protected void
RemovePeerProcedure.postPeerModification
(MasterProcedureEnv env) protected void
AddPeerProcedure.prePeerModification
(MasterProcedureEnv env) protected abstract void
ModifyPeerProcedure.prePeerModification
(MasterProcedureEnv env) Called before we start the actual processing.protected final ProcedureSuspendedException
AbstractPeerNoLockProcedure.suspend
(org.apache.hadoop.conf.Configuration conf, LongConsumer backoffConsumer) private ProcedureSuspendedException
MigrateReplicationQueueFromZkToTableProcedure.suspend
(org.apache.hadoop.conf.Configuration conf, LongConsumer backoffConsumer) private void
MigrateReplicationQueueFromZkToTableProcedure.waitUntilNoPeerProcedure
(MasterProcedureEnv env) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.snapshot
Modifier and TypeMethodDescriptionSnapshotManager.acquireSnapshotVerifyWorker
(SnapshotVerifyProcedure procedure) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.procedure2
Modifier and TypeMethodDescriptionprotected final ProcedureSuspendedException
Procedure.suspend
(int timeoutMillis, boolean jitter) Modifier and TypeMethodDescriptionprotected Procedure<TEnvironment>[]
Procedure.doExecute
(TEnvironment env) Internal method called by the ProcedureExecutor that starts the user-level code execute().protected Procedure[]
SequentialProcedure.doExecute
(TEnvironment env) protected Procedure<TEnvironment>[]
FailedProcedure.execute
(TEnvironment env) protected abstract Procedure<TEnvironment>[]
Procedure.execute
(TEnvironment env) The main code of the procedure.protected Procedure[]
StateMachineProcedure.execute
(TEnvironment env) protected abstract StateMachineProcedure.Flow
StateMachineProcedure.executeFromState
(TEnvironment env, TState state) called to perform a single step of the specified 'state' of the procedureprotected final ProcedureSuspendedException
Procedure.suspend
(int timeoutMillis, boolean jitter) static void
static void
ProcedureFutureUtil.suspendIfNecessary
(Procedure<?> proc, Consumer<CompletableFuture<Void>> setFuture, CompletableFuture<Void> future, MasterProcedureEnv env, Runnable actionAfterDone) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.regionserver.storefiletracker
Modifier and TypeMethodDescriptionprotected StateMachineProcedure.Flow
ModifyStoreFileTrackerProcedure.executeFromState
(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyStoreFileTrackerState state)