public static class TestRegionBypass.StallingAssignProcedure extends org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure
org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure.TransitionType
org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
Modifier and Type | Field and Description |
---|---|
CountDownLatch |
latch |
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) |
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) |
assign, assign, attachRemoteProc, deserializeStateData, execute, getInitialState, getProcedureMetrics, getState, getStateId, getTableOperationType, move, reopen, reportTransition, rollbackState, serializeStateData, serverCrashed, setTimeoutFailure, stateLoaded, toStringClassDetails, unassign, unattachRemoteProc, waitInitialized
acquireLock, checkTableModifiable, getRegion, getTableName, holdLock, releaseLock, setFailure, setRegion
checkOnline, getUser, getWALRegionDir, preflightChecks, releaseSyncLatch, setUser
abort, addChildProcedure, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, isRollbackSupported, isYieldAfterExecutionStep, isYieldBeforeExecuteFromState, rollback, setNextState, toStringState
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
public final CountDownLatch latch
public 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)
private void init(org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv env)
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
executeFromState
in class org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException
org.apache.hadoop.hbase.procedure2.ProcedureYieldException
InterruptedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.