Class TestRegionBypass.StallingAssignProcedure
java.lang.Object
org.apache.hadoop.hbase.procedure2.Procedure<TEnvironment>
org.apache.hadoop.hbase.procedure2.StateMachineProcedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv,TState>
org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure<TState>
org.apache.hadoop.hbase.master.procedure.AbstractStateMachineRegionProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RegionStateTransitionState>
org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure
org.apache.hadoop.hbase.master.assignment.TestRegionBypass.StallingAssignProcedure
- All Implemented Interfaces:
Comparable<org.apache.hadoop.hbase.procedure2.Procedure<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>>
,org.apache.hadoop.hbase.master.procedure.TableProcedureInterface
- Enclosing class:
- TestRegionBypass
public static class TestRegionBypass.StallingAssignProcedure
extends org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure
An AssignProcedure that Stalls just before the finish.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure
org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure.TransitionType
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure
org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.Procedure
org.apache.hadoop.hbase.procedure2.Procedure.LockState
Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.master.procedure.TableProcedureInterface
org.apache.hadoop.hbase.master.procedure.TableProcedureInterface.TableOperationType
-
Field Summary
Fields inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure
stateCount
Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure
NO_PROC_ID, NO_TIMEOUT
-
Constructor Summary
ConstructorDescriptionStallingAssignProcedure
(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, org.apache.hadoop.hbase.client.RegionInfo hri, org.apache.hadoop.hbase.ServerName assignCandidate, boolean forceNewPlan, org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure.TransitionType type) -
Method Summary
Modifier and TypeMethodDescriptionprotected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
executeFromState
(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RegionStateTransitionState state) private void
init
(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env) Methods inherited from class org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure
assign, assign, attachRemoteProc, deserializeStateData, execute, getInitialState, getProcedureMetrics, getState, getStateId, getTableOperationType, move, reopen, reportTransition, rollbackState, serializeStateData, serverCrashed, setTimeoutFailure, stateLoaded, toStringClassDetails, unassign, unassignSplitMerge, unattachRemoteProc, waitInitialized
Methods inherited from class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineRegionProcedure
acquireLock, getRegion, getTableName, holdLock, releaseLock, setFailure, setRegion
Methods inherited from class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure
checkOnline, checkTableModifiable, getUser, getWALRegionDir, isTableEnabled, preflightChecks, releaseSyncLatch, setUser
Methods inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure
abort, addChildProcedure, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, setNextState, toStringState
Methods inherited from class org.apache.hadoop.hbase.procedure2.Procedure
addStackIndex, afterReplay, beforeReplay, bypass, compareTo, completionCleanup, doExecute, doRollback, elapsedTime, getChildrenLatch, getException, getLastUpdate, getNonceKey, getOwner, getParentProcId, getProcId, getProcIdHashCode, getProcName, getResult, getRootProcedureId, getRootProcId, getStackIndexes, getState, getSubmittedTime, getTimeout, getTimeoutTimestamp, hasChildren, hasException, hasLock, hasOwner, hasParent, hasTimeout, haveSameParent, incChildrenLatch, isBypass, isFailed, isFinished, isInitializing, isLockedWhenLoading, isRunnable, isSuccess, isWaiting, removeStackIndex, setAbortFailure, setChildrenLatch, setExecuted, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, shouldWaitClientAck, skipPersistence, suspend, toString, toStringClass, toStringDetails, toStringSimpleSB, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, wasExecuted
-
Field Details
-
latch
-
-
Constructor Details
-
StallingAssignProcedure
public StallingAssignProcedure() -
StallingAssignProcedure
public StallingAssignProcedure(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, org.apache.hadoop.hbase.client.RegionInfo hri, org.apache.hadoop.hbase.ServerName assignCandidate, boolean forceNewPlan, org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure.TransitionType type)
-
-
Method Details
-
init
-
executeFromState
protected org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow executeFromState(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RegionStateTransitionState state) throws org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException, org.apache.hadoop.hbase.procedure2.ProcedureYieldException, InterruptedException - Overrides:
executeFromState
in classorg.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure
- Throws:
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
org.apache.hadoop.hbase.procedure2.ProcedureYieldException
InterruptedException
-