org.apache.hadoop.hbase.regionserver.storefiletracker

Class ModifyColumnFamilyStoreFileTrackerProcedure

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.ModifyStoreFileTrackerState>

org.apache.hadoop.hbase.regionserver.storefiletracker.ModifyStoreFileTrackerProcedure

org.apache.hadoop.hbase.regionserver.storefiletracker.ModifyColumnFamilyStoreFileTrackerProcedure

All Implemented Interfaces:

Comparable<Procedure<MasterProcedureEnv>>, TableProcedureInterface

@InterfaceAudience.Private
public class ModifyColumnFamilyStoreFileTrackerProcedure
extends ModifyStoreFileTrackerProcedure

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 and Description
private byte[]	family

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 and Description
ModifyColumnFamilyStoreFileTrackerProcedure()
ModifyColumnFamilyStoreFileTrackerProcedure(MasterProcedureEnv env, TableName tableName, byte[] family, String dstSFT)

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.conf.Configuration	createConf(org.apache.hadoop.conf.Configuration conf, TableDescriptor current)
protected TableDescriptor	createFinishTableDescriptor(TableDescriptor current)
protected TableDescriptor	createMigrationTableDescriptor(org.apache.hadoop.conf.Configuration conf, TableDescriptor current)
protected TableDescriptor	createRestoreTableDescriptor(TableDescriptor current, String restoreSFT)
protected void	deserializeStateData(ProcedureStateSerializer serializer) Called on store load to allow the user to decode the previously serialized state.
protected void	preCheck(TableDescriptor current)
protected void	serializeStateData(ProcedureStateSerializer serializer) The user-level code of the procedure may have some state to persist (e.g.

Methods inherited from class org.apache.hadoop.hbase.regionserver.storefiletracker.ModifyStoreFileTrackerProcedure

executeFromState, finish, getInitialState, getState, getStateId, getTableName, getTableOperationType, isRollbackSupported, migrate, rollbackState

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, 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, holdLock, 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, setTimeoutFailure, shouldWaitClientAck, skipPersistence, 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 Detail

family

private byte[] family

Constructor Detail

ModifyColumnFamilyStoreFileTrackerProcedure

public ModifyColumnFamilyStoreFileTrackerProcedure()

ModifyColumnFamilyStoreFileTrackerProcedure

public ModifyColumnFamilyStoreFileTrackerProcedure(MasterProcedureEnv env,
                                                   TableName tableName,
                                                   byte[] family,
                                                   String dstSFT)
                                            throws HBaseIOException

Throws:

HBaseIOException

Method Detail

preCheck

protected void preCheck(TableDescriptor current)
                 throws IOException

Specified by:

preCheck in class ModifyStoreFileTrackerProcedure

Throws:

IOException

createConf

protected org.apache.hadoop.conf.Configuration createConf(org.apache.hadoop.conf.Configuration conf,
                                                          TableDescriptor current)

Specified by:

createConf in class ModifyStoreFileTrackerProcedure

createRestoreTableDescriptor

protected TableDescriptor createRestoreTableDescriptor(TableDescriptor current,
                                                       String restoreSFT)

Specified by:

createRestoreTableDescriptor in class ModifyStoreFileTrackerProcedure

createMigrationTableDescriptor

protected TableDescriptor createMigrationTableDescriptor(org.apache.hadoop.conf.Configuration conf,
                                                         TableDescriptor current)

Specified by:

createMigrationTableDescriptor in class ModifyStoreFileTrackerProcedure

createFinishTableDescriptor

protected TableDescriptor createFinishTableDescriptor(TableDescriptor current)

Specified by:

createFinishTableDescriptor in class ModifyStoreFileTrackerProcedure

serializeStateData

protected void serializeStateData(ProcedureStateSerializer serializer)
                           throws IOException

Description copied from class: Procedure

The user-level code of the procedure may have some state to persist (e.g. input arguments or current position in the processing state) to be able to resume on failure.

Overrides:

serializeStateData in class ModifyStoreFileTrackerProcedure

Parameters:

serializer - stores the serializable state

Throws:

IOException

deserializeStateData

protected void deserializeStateData(ProcedureStateSerializer serializer)
                             throws IOException

Description copied from class: Procedure

Called on store load to allow the user to decode the previously serialized state.

Overrides:

deserializeStateData in class ModifyStoreFileTrackerProcedure

Parameters:

serializer - contains the serialized state

Throws:

IOException