Package org.apache.hadoop.hbase.rsgroup

Class MigrateRSGroupProcedure

java.lang.Object

org.apache.hadoop.hbase.procedure2.Procedure<TEnvironment>

org.apache.hadoop.hbase.procedure2.StateMachineProcedure<MasterProcedureEnv,TState>

org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableDescriptorState>

org.apache.hadoop.hbase.master.procedure.ModifyTableDescriptorProcedure

org.apache.hadoop.hbase.rsgroup.MigrateRSGroupProcedure

All Implemented Interfaces:

Comparable<Procedure<MasterProcedureEnv>>, TableProcedureInterface

@Private
public class MigrateRSGroupProcedure
extends ModifyTableDescriptorProcedure

Procedure for migrating rs group information to table descriptor.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure

StateMachineProcedure.Flow

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.procedure2.Procedure

Procedure.LockState

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.master.procedure.TableProcedureInterface

TableProcedureInterface.TableOperationType

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

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

Fields inherited from interface org.apache.hadoop.hbase.master.procedure.TableProcedureInterface

DUMMY_NAMESPACE_TABLE_NAME

Constructor Summary

Constructors

Constructor	Description
MigrateRSGroupProcedure()
MigrateRSGroupProcedure(MasterProcedureEnv env, TableName tableName)

Method Summary

Modifier and Type	Method	Description
protected Optional<TableDescriptor>	modify(MasterProcedureEnv env, TableDescriptor current)	Sub class should implement this method to modify the table descriptor, such as storing the rs group information.

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

deserializeStateData, executeFromState, getInitialState, getState, getStateId, getTableName, getTableOperationType, holdLock, isRollbackSupported, rollbackState, serializeStateData

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

acquireLock, checkOnline, checkTableModifiable, getUser, getWALRegionDir, isTableEnabled, preflightChecks, releaseLock, releaseSyncLatch, setUser, toStringClassDetails, waitInitialized

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

abort, addChildProcedure, execute, failIfAborted, getCurrentState, getCurrentStateId, getCycles, isEofState, 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, getProcedureMetrics, 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, setTimeoutFailure, shouldWaitClientAck, skipPersistence, suspend, 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 Details

LOG

private static final org.slf4j.Logger LOG

Constructor Details

MigrateRSGroupProcedure

public MigrateRSGroupProcedure()

MigrateRSGroupProcedure

public MigrateRSGroupProcedure(MasterProcedureEnv env,
 TableName tableName)

Method Details

modify

protected Optional<TableDescriptor> modify(MasterProcedureEnv env,
 TableDescriptor current)
                                    throws IOException

Description copied from class: ModifyTableDescriptorProcedure

Sub class should implement this method to modify the table descriptor, such as storing the rs group information.

Since the migrating is asynchronouns, it is possible that users have already changed the rs group for a table, in this case we do not need to modify the table descriptor any more, then you could just return Optional.empty().

Specified by:

modify in class ModifyTableDescriptorProcedure

Throws:

IOException