Package org.apache.hadoop.hbase.regionserver.storefiletracker

Class InitializeStoreFileTrackerProcedure

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.regionserver.storefiletracker.InitializeStoreFileTrackerProcedure

All Implemented Interfaces:

Comparable<Procedure<MasterProcedureEnv>>, TableProcedureInterface

@Private
public class InitializeStoreFileTrackerProcedure
extends ModifyTableDescriptorProcedure

Procedure for setting StoreFileTracker 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 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

Constructor Summary

Constructors

Constructor	Description
InitializeStoreFileTrackerProcedure()
InitializeStoreFileTrackerProcedure(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

Constructor Details

InitializeStoreFileTrackerProcedure

public InitializeStoreFileTrackerProcedure()

InitializeStoreFileTrackerProcedure

public InitializeStoreFileTrackerProcedure(MasterProcedureEnv env,
 TableName tableName)

Method Details

modify

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

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