public class AssignProcedure extends RegionTransitionProcedure
The Assign starts by pushing the "assign" operation to the AssignmentManager and then will go in a "waiting" state. The AM will batch the "assign" requests and ask the Balancer where to put the region (the various policies will be respected: retain, round-robin, random). Once the AM and the balancer have found a place for the region the procedure will be resumed and an "open region" request will be placed in the Remote Dispatcher queue, and the procedure once again will go in a "waiting state". The Remote Dispatcher will batch the various requests for that server and they will be sent to the RS for execution. The RS will complete the open operation by calling master.reportRegionStateTransition(). The AM will intercept the transition report, and notify the procedure. The procedure will finish the assignment by publishing to new state on meta or it will retry the assignment.
This procedure does not rollback when beyond the first REGION_TRANSITION_QUEUE step; it will press on trying to assign in the face of failure. Should we ignore rollback calls to Assign/Unassign then? Or just remove rollback here?
Modifier and Type | Class and Description |
---|---|
static class |
AssignProcedure.CompareAssignProcedure
Sort AssignProcedures such that meta and system assigns come first before user-space assigns.
|
TableProcedureInterface.TableOperationType
Modifier and Type | Field and Description |
---|---|
static AssignProcedure.CompareAssignProcedure |
COMPARATOR
Comparator that will sort AssignProcedures so meta assigns come first, then system table
assigns and finally user space assigns.
|
protected ServerName |
targetServer
Gets set as desired target on move, merge, etc., when we want to go to a particular server.
|
aborted
Constructor and Description |
---|
AssignProcedure() |
AssignProcedure(RegionInfo regionInfo) |
AssignProcedure(RegionInfo regionInfo,
ServerName destinationServer) |
Modifier and Type | Method and Description |
---|---|
protected void |
deserializeStateData(ProcedureStateSerializer serializer) |
protected void |
finishTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
protected ProcedureMetrics |
getProcedureMetrics(MasterProcedureEnv env) |
ServerName |
getServer(MasterProcedureEnv env)
Used by ServerCrashProcedure to see if this Assign/Unassign needs processing.
|
TableProcedureInterface.TableOperationType |
getTableOperationType()
Given an operation type we can take decisions about what to do with pending operations.
|
protected boolean |
isRollbackSupported(RegionTransitionState state) |
RemoteOperation |
remoteCallBuild(MasterProcedureEnv env,
ServerName serverName) |
protected boolean |
remoteCallFailed(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
java.io.IOException exception) |
protected void |
reportTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode,
TransitionCode code,
long openSeqNum) |
protected void |
serializeStateData(ProcedureStateSerializer serializer) |
protected boolean |
startTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode) |
void |
toStringClassDetails(java.lang.StringBuilder sb) |
protected boolean |
updateTransition(MasterProcedureEnv env,
RegionStates.RegionStateNode regionNode)
Called when the Procedure is in the REGION_TRANSITION_DISPATCH state.
|
abort, acquireLock, addToRemoteDispatcher, execute, getAttempt, getRegionInfo, getRegionState, getTableName, hasLock, holdLock, isMeta, isServerOnline, isServerOnline, releaseLock, remoteCallCompleted, rollback, setAttempt, setRegionInfo, setTimeoutFailure, shouldWaitClientAck, toStringState
protected volatile ServerName targetServer
public static final AssignProcedure.CompareAssignProcedure COMPARATOR
public AssignProcedure()
public AssignProcedure(RegionInfo regionInfo)
public AssignProcedure(RegionInfo regionInfo, ServerName destinationServer)
public TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterface
protected boolean isRollbackSupported(RegionTransitionState state)
isRollbackSupported
in class RegionTransitionProcedure
protected void serializeStateData(ProcedureStateSerializer serializer) throws java.io.IOException
java.io.IOException
protected void deserializeStateData(ProcedureStateSerializer serializer) throws java.io.IOException
java.io.IOException
protected boolean startTransition(MasterProcedureEnv env, RegionStates.RegionStateNode regionNode) throws java.io.IOException
startTransition
in class RegionTransitionProcedure
java.io.IOException
protected boolean updateTransition(MasterProcedureEnv env, RegionStates.RegionStateNode regionNode) throws java.io.IOException, ProcedureSuspendedException
RegionTransitionProcedure
updateTransition
in class RegionTransitionProcedure
java.io.IOException
ProcedureSuspendedException
protected void finishTransition(MasterProcedureEnv env, RegionStates.RegionStateNode regionNode) throws java.io.IOException
finishTransition
in class RegionTransitionProcedure
java.io.IOException
protected void reportTransition(MasterProcedureEnv env, RegionStates.RegionStateNode regionNode, TransitionCode code, long openSeqNum) throws UnexpectedStateException
reportTransition
in class RegionTransitionProcedure
UnexpectedStateException
public RemoteOperation remoteCallBuild(MasterProcedureEnv env, ServerName serverName)
remoteCallBuild
in class RegionTransitionProcedure
protected boolean remoteCallFailed(MasterProcedureEnv env, RegionStates.RegionStateNode regionNode, java.io.IOException exception)
remoteCallFailed
in class RegionTransitionProcedure
public void toStringClassDetails(java.lang.StringBuilder sb)
toStringClassDetails
in class RegionTransitionProcedure
public ServerName getServer(MasterProcedureEnv env)
RegionTransitionProcedure
getServer
in class RegionTransitionProcedure
protected ProcedureMetrics getProcedureMetrics(MasterProcedureEnv env)