public class MergeTableRegionsProcedure extends AbstractStateMachineTableProcedure<MergeTableRegionsState>
Throws exception on construction if determines context hostile to merge (cluster going down or master is shutting down or table is disabled).
TableProcedureInterface.TableOperationType
Constructor and Description |
---|
MergeTableRegionsProcedure() |
MergeTableRegionsProcedure(MasterProcedureEnv env,
RegionInfo[] regionsToMerge,
boolean forcible) |
MergeTableRegionsProcedure(MasterProcedureEnv env,
RegionInfo regionToMergeA,
RegionInfo regionToMergeB) |
MergeTableRegionsProcedure(MasterProcedureEnv env,
RegionInfo regionToMergeA,
RegionInfo regionToMergeB,
boolean forcible) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
abort(MasterProcedureEnv env) |
protected LockState |
acquireLock(MasterProcedureEnv env) |
protected void |
deserializeStateData(ProcedureStateSerializer serializer) |
protected Flow |
executeFromState(MasterProcedureEnv env,
MergeTableRegionsState state) |
protected MergeTableRegionsState |
getInitialState() |
RegionInfo |
getMergedRegion() |
protected ProcedureMetrics |
getProcedureMetrics(MasterProcedureEnv env) |
protected MergeTableRegionsState |
getState(int stateId) |
protected int |
getStateId(MergeTableRegionsState state) |
TableName |
getTableName() |
TableProcedureInterface.TableOperationType |
getTableOperationType()
Given an operation type we can take decisions about what to do with pending operations.
|
protected boolean |
hasLock(MasterProcedureEnv env) |
protected boolean |
holdLock(MasterProcedureEnv env) |
protected boolean |
isRollbackSupported(MergeTableRegionsState state) |
protected void |
releaseLock(MasterProcedureEnv env) |
protected void |
rollbackState(MasterProcedureEnv env,
MergeTableRegionsState state)
To rollback
MergeTableRegionsProcedure , two AssignProcedures are asynchronously
submitted for each region to be merged (rollback doesn't wait on the completion of the
AssignProcedures) . |
protected void |
serializeStateData(ProcedureStateSerializer serializer) |
void |
setRegionStateToMerging(MasterProcedureEnv env)
Set the region states to MERGING state
|
void |
toStringClassDetails(java.lang.StringBuilder sb) |
checkOnline, checkTableModifiable, getRegionDir, getUser, preflightChecks, releaseSyncLatch, setUser
public MergeTableRegionsProcedure()
public MergeTableRegionsProcedure(MasterProcedureEnv env, RegionInfo regionToMergeA, RegionInfo regionToMergeB) throws java.io.IOException
java.io.IOException
public MergeTableRegionsProcedure(MasterProcedureEnv env, RegionInfo regionToMergeA, RegionInfo regionToMergeB, boolean forcible) throws java.io.IOException
java.io.IOException
public MergeTableRegionsProcedure(MasterProcedureEnv env, RegionInfo[] regionsToMerge, boolean forcible) throws java.io.IOException
java.io.IOException
protected Flow executeFromState(MasterProcedureEnv env, MergeTableRegionsState state)
protected void rollbackState(MasterProcedureEnv env, MergeTableRegionsState state) throws java.io.IOException
MergeTableRegionsProcedure
, two AssignProcedures are asynchronously
submitted for each region to be merged (rollback doesn't wait on the completion of the
AssignProcedures) . This can be improved by changing rollback() to support sub-procedures.
See HBASE-19851 for details.java.io.IOException
protected boolean isRollbackSupported(MergeTableRegionsState state)
protected MergeTableRegionsState getState(int stateId)
protected int getStateId(MergeTableRegionsState state)
protected MergeTableRegionsState getInitialState()
protected void serializeStateData(ProcedureStateSerializer serializer) throws java.io.IOException
java.io.IOException
protected void deserializeStateData(ProcedureStateSerializer serializer) throws java.io.IOException
java.io.IOException
public void toStringClassDetails(java.lang.StringBuilder sb)
toStringClassDetails
in class AbstractStateMachineTableProcedure<MergeTableRegionsState>
protected LockState acquireLock(MasterProcedureEnv env)
acquireLock
in class AbstractStateMachineTableProcedure<MergeTableRegionsState>
protected void releaseLock(MasterProcedureEnv env)
releaseLock
in class AbstractStateMachineTableProcedure<MergeTableRegionsState>
protected boolean holdLock(MasterProcedureEnv env)
protected boolean hasLock(MasterProcedureEnv env)
public TableName getTableName()
getTableName
in interface TableProcedureInterface
getTableName
in class AbstractStateMachineTableProcedure<MergeTableRegionsState>
public TableProcedureInterface.TableOperationType getTableOperationType()
TableProcedureInterface
getTableOperationType
in interface TableProcedureInterface
getTableOperationType
in class AbstractStateMachineTableProcedure<MergeTableRegionsState>
protected ProcedureMetrics getProcedureMetrics(MasterProcedureEnv env)
public void setRegionStateToMerging(MasterProcedureEnv env)
env
- MasterProcedureEnvpublic RegionInfo getMergedRegion()
protected boolean abort(MasterProcedureEnv env)