Uses of Class
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
Packages that use ProcedureSuspendedException
Package
Description
-
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master
Methods in org.apache.hadoop.hbase.master that throw ProcedureSuspendedExceptionModifier and TypeMethodDescriptionSplitWALManager.acquireSplitWALWorker(Procedure<?> procedure) Acquire a split WAL worker -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.assignment
Methods in org.apache.hadoop.hbase.master.assignment that throw ProcedureSuspendedExceptionModifier and TypeMethodDescriptionvoidRegionStateNodeLock.QueueEntry.await()Called when we can not hold the lock and should wait.protected voidRegionRemoteProcedureBase.beforeExec(MasterProcedureEnv env) protected voidTransitRegionStateProcedure.beforeExec(MasterProcedureEnv env) private voidTransitRegionStateProcedure.checkAndWaitForOriginalServer(MasterProcedureEnv env, ServerName lastHost) private voidTransitRegionStateProcedure.closeRegion(MasterProcedureEnv env, RegionStateNode regionNode) private StateMachineProcedure.FlowTransitRegionStateProcedure.confirmOpened(MasterProcedureEnv env, RegionStateNode regionNode) protected Procedure<MasterProcedureEnv>[]RegionRemoteProcedureBase.execute(MasterProcedureEnv env) protected StateMachineProcedure.FlowGCMergedRegionsProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCMergedRegionsState state) Deprecated.protected StateMachineProcedure.FlowGCMultipleMergedRegionsProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCMergedRegionsState state) protected StateMachineProcedure.FlowGCRegionProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.GCRegionState state) protected StateMachineProcedure.FlowTransitRegionStateProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RegionStateTransitionState state) protected abstract voidRegionTransitionProcedure.finishTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.void(package private) voidLock by a procedure.private voidRegionStateNodeLock.lock0(RegionStateNodeLock.QueueEntry entry) private voidTransitRegionStateProcedure.openRegion(MasterProcedureEnv env, RegionStateNode regionNode) private voidTransitRegionStateProcedure.queueAssign(MasterProcedureEnv env, RegionStateNode regionNode) protected abstract booleanRegionTransitionProcedure.startTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected booleanAssignProcedure.updateTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated.protected abstract booleanRegionTransitionProcedure.updateTransition(MasterProcedureEnv env, RegionStateNode regionNode) Deprecated. -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.locking
Methods in org.apache.hadoop.hbase.master.locking that throw ProcedureSuspendedExceptionModifier and TypeMethodDescriptionprotected Procedure<MasterProcedureEnv>[]LockProcedure.execute(MasterProcedureEnv env) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.procedure
Methods in org.apache.hadoop.hbase.master.procedure that throw ProcedureSuspendedExceptionModifier and TypeMethodDescriptionprivate voidServerCrashProcedure.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.FlowAbstractCloseTableRegionsProcedure.executeFromState(MasterProcedureEnv env, TState state) protected StateMachineProcedure.FlowCreateTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.CreateTableState state) protected StateMachineProcedure.FlowDeleteTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteTableState state) protected StateMachineProcedure.FlowFlushTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.FlushTableState state) protected StateMachineProcedure.FlowInitMetaProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.InitMetaState state) protected StateMachineProcedure.FlowLogRollProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.LogRollProcedureState state) protected StateMachineProcedure.FlowMigrateNamespaceTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MigrateNamespaceTableProcedureState state) protected StateMachineProcedure.FlowModifyTableDescriptorProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableDescriptorState state) protected StateMachineProcedure.FlowRecoverMetaProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverMetaState state) Deprecated.protected StateMachineProcedure.FlowReopenTableRegionsProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ReopenTableRegionsState state) protected StateMachineProcedure.FlowRestoreBackupSystemTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RestoreBackupSystemTableState state) protected StateMachineProcedure.FlowServerCrashProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ServerCrashState state) protected StateMachineProcedure.FlowSnapshotProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SnapshotState state) protected StateMachineProcedure.FlowSplitWALProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitWALState state) protected StateMachineProcedure.FlowSwitchRpcThrottleProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SwitchRpcThrottleState state) private voidSnapshotProcedure.prepareSnapshot(MasterProcedureEnv env) private StateMachineProcedure.FlowReopenTableRegionsProcedure.reopenIfSchedulable(MasterProcedureEnv env, List<HRegionLocation> regionsToReopen, boolean shouldBatchBackoff) private StateMachineProcedure.FlowAbstractCloseTableRegionsProcedure.schedule(MasterProcedureEnv env) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.replication
Methods in org.apache.hadoop.hbase.master.replication that return ProcedureSuspendedExceptionModifier and TypeMethodDescriptionprotected final ProcedureSuspendedExceptionAbstractPeerNoLockProcedure.suspend(org.apache.hadoop.conf.Configuration conf, LongConsumer backoffConsumer) private ProcedureSuspendedExceptionMigrateReplicationQueueFromZkToTableProcedure.suspend(org.apache.hadoop.conf.Configuration conf, LongConsumer backoffConsumer) Methods in org.apache.hadoop.hbase.master.replication that throw ProcedureSuspendedExceptionModifier and TypeMethodDescriptionSyncReplicationReplayWALManager.acquirePeerWorker(String peerId, Procedure<?> proc) Get a worker for replaying remote wal for a give peer.private voidRemovePeerProcedure.checkAssignReplicationQueuesFinished(MasterProcedureEnv env) private voidMigrateReplicationQueueFromZkToTableProcedure.cleanup(MasterProcedureEnv env) private voidMigrateReplicationQueueFromZkToTableProcedure.disableReplicationLogCleaner(MasterProcedureEnv env) protected Procedure<MasterProcedureEnv>[]ClaimReplicationQueueRemoteProcedure.execute(MasterProcedureEnv env) protected Procedure<MasterProcedureEnv>[]ClaimReplicationQueuesProcedure.execute(MasterProcedureEnv env) Deprecated.protected StateMachineProcedure.FlowAssignReplicationQueuesProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.AssignReplicationQueuesState state) protected StateMachineProcedure.FlowMigrateReplicationQueueFromZkToTableProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MigrateReplicationQueueFromZkToTableState state) protected StateMachineProcedure.FlowModifyPeerProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerModificationState state) protected StateMachineProcedure.FlowRecoverStandbyProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverStandbyState state) protected StateMachineProcedure.FlowSyncReplicationReplayWALProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SyncReplicationReplayWALState state) protected StateMachineProcedure.FlowTransitPeerSyncReplicationStateProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerSyncReplicationStateTransitionState state) protected abstract voidModifyPeerProcedure.postPeerModification(MasterProcedureEnv env) Called before we finish the procedure.protected voidRemovePeerProcedure.postPeerModification(MasterProcedureEnv env) protected voidAddPeerProcedure.prePeerModification(MasterProcedureEnv env) protected abstract voidModifyPeerProcedure.prePeerModification(MasterProcedureEnv env) Called before we start the actual processing.protected final ProcedureSuspendedExceptionAbstractPeerNoLockProcedure.suspend(org.apache.hadoop.conf.Configuration conf, LongConsumer backoffConsumer) private ProcedureSuspendedExceptionMigrateReplicationQueueFromZkToTableProcedure.suspend(org.apache.hadoop.conf.Configuration conf, LongConsumer backoffConsumer) private voidMigrateReplicationQueueFromZkToTableProcedure.waitUntilNoPeerProcedure(MasterProcedureEnv env) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.master.snapshot
Methods in org.apache.hadoop.hbase.master.snapshot that throw ProcedureSuspendedExceptionModifier and TypeMethodDescriptionSnapshotManager.acquireSnapshotVerifyWorker(SnapshotVerifyProcedure procedure) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.procedure2
Methods in org.apache.hadoop.hbase.procedure2 that return ProcedureSuspendedExceptionModifier and TypeMethodDescriptionprotected final ProcedureSuspendedExceptionProcedure.suspend(int timeoutMillis, boolean jitter) Methods in org.apache.hadoop.hbase.procedure2 that throw ProcedureSuspendedExceptionModifier and TypeMethodDescriptionprotected voidProcedure.beforeExec(TEnvironment env) Called before we call the execute method of this procedure, but after we acquire the execution lock and procedure scheduler lock.protected 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.FlowStateMachineProcedure.executeFromState(TEnvironment env, TState state) called to perform a single step of the specified 'state' of the procedureprotected final ProcedureSuspendedExceptionProcedure.suspend(int timeoutMillis, boolean jitter) static voidstatic voidProcedureFutureUtil.suspendIfNecessary(Procedure<?> proc, Consumer<CompletableFuture<Void>> setFuture, CompletableFuture<Void> future, MasterProcedureEnv env, Runnable actionAfterDone) -
Uses of ProcedureSuspendedException in org.apache.hadoop.hbase.regionserver.storefiletracker
Methods in org.apache.hadoop.hbase.regionserver.storefiletracker that throw ProcedureSuspendedExceptionModifier and TypeMethodDescriptionprotected StateMachineProcedure.FlowModifyStoreFileTrackerProcedure.executeFromState(MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyStoreFileTrackerState state)