org.apache.hadoop.hbase.master.assignment

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

Modifier and Type	Field and Description
CountDownLatch	latch

Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure

NO_PROC_ID, NO_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
StallingAssignProcedure()
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 Summary

Modifier and Type	Method and Description
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)
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, unattachRemoteProc, waitInitialized

Methods inherited from class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineRegionProcedure

acquireLock, checkTableModifiable, getRegion, getTableName, holdLock, releaseLock, setFailure, setRegion

Methods inherited from class org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure

checkOnline, getUser, getWALRegionDir, preflightChecks, releaseSyncLatch, setUser

Methods inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure

abort, addChildProcedure, failIfAborted, getCurrentState, getCurrentStateId, getCycles, 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, setFailure, setFailure, setLastUpdate, setNonceKey, setOwner, setOwner, setParentProcId, setProcId, setResult, setRootProcId, setStackIndexes, setState, setSubmittedTime, setTimeout, shouldWaitClientAck, skipPersistence, toString, toStringClass, toStringDetails, toStringSimpleSB, updateMetricsOnFinish, updateMetricsOnSubmit, updateTimestamp, wasExecuted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

latch

public final CountDownLatch latch

Constructor Detail

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 Detail

init

private void init(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)

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 class org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure

Throws:

org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException

org.apache.hadoop.hbase.procedure2.ProcedureYieldException

InterruptedException