org.apache.hadoop.hbase.master.procedure

Class CreateTableProcedure

java.lang.Object

<any>

org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedure<CreateTableState>

org.apache.hadoop.hbase.master.procedure.CreateTableProcedure

All Implemented Interfaces:

TableProcedureInterface

public class CreateTableProcedure
extends AbstractStateMachineTableProcedure<CreateTableState>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	CreateTableProcedure.CreateHdfsRegions

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

TableProcedureInterface.TableOperationType

Constructor Summary

Constructors

Constructor and Description
CreateTableProcedure()
CreateTableProcedure(MasterProcedureEnv env, TableDescriptor tableDescriptor, RegionInfo[] newRegions)
CreateTableProcedure(MasterProcedureEnv env, TableDescriptor tableDescriptor, RegionInfo[] newRegions, ProcedurePrepareLatch syncLatch)

Method Summary

Modifier and Type	Method and Description
protected LockState	acquireLock(MasterProcedureEnv env)
protected static java.util.List<RegionInfo>	addTableToMeta(MasterProcedureEnv env, TableDescriptor tableDescriptor, java.util.List<RegionInfo> regions)
protected static java.util.List<RegionInfo>	createFsLayout(MasterProcedureEnv env, TableDescriptor tableDescriptor, java.util.List<RegionInfo> newRegions)
protected static java.util.List<RegionInfo>	createFsLayout(MasterProcedureEnv env, TableDescriptor tableDescriptor, java.util.List<RegionInfo> newRegions, CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler)
protected void	deserializeStateData(ProcedureStateSerializer serializer)
protected Flow	executeFromState(MasterProcedureEnv env, CreateTableState state)
protected CreateTableState	getInitialState()
protected CreateTableState	getState(int stateId)
protected int	getStateId(CreateTableState state)
TableName	getTableName()
TableProcedureInterface.TableOperationType	getTableOperationType() Given an operation type we can take decisions about what to do with pending operations.
protected boolean	isRollbackSupported(CreateTableState state)
protected static void	moveTempDirectoryToHBaseRoot(MasterProcedureEnv env, TableDescriptor tableDescriptor, Path tempTableDir)
protected void	rollbackState(MasterProcedureEnv env, CreateTableState state)
protected void	serializeStateData(ProcedureStateSerializer serializer)
protected static void	setEnabledState(MasterProcedureEnv env, TableName tableName)
protected static void	setEnablingState(MasterProcedureEnv env, TableName tableName)
protected boolean	shouldWaitClientAck(MasterProcedureEnv env)
protected static void	updateTableDescCache(MasterProcedureEnv env, TableName tableName)

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

checkOnline, checkTableModifiable, getRegionDir, getUser, preflightChecks, releaseLock, releaseSyncLatch, setUser, toStringClassDetails

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CreateTableProcedure

public CreateTableProcedure()

CreateTableProcedure

public CreateTableProcedure(MasterProcedureEnv env,
                            TableDescriptor tableDescriptor,
                            RegionInfo[] newRegions)

CreateTableProcedure

public CreateTableProcedure(MasterProcedureEnv env,
                            TableDescriptor tableDescriptor,
                            RegionInfo[] newRegions,
                            ProcedurePrepareLatch syncLatch)

Method Detail

executeFromState

protected Flow executeFromState(MasterProcedureEnv env,
                                CreateTableState state)
                         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

rollbackState

protected void rollbackState(MasterProcedureEnv env,
                             CreateTableState state)
                      throws java.io.IOException

Throws:

java.io.IOException

isRollbackSupported

protected boolean isRollbackSupported(CreateTableState state)

getState

protected CreateTableState getState(int stateId)

getStateId

protected int getStateId(CreateTableState state)

getInitialState

protected CreateTableState getInitialState()

getTableName

public TableName getTableName()

Specified by:

getTableName in interface TableProcedureInterface

Specified by:

getTableName in class AbstractStateMachineTableProcedure<CreateTableState>

Returns:

the name of the table the procedure is operating on

getTableOperationType

public TableProcedureInterface.TableOperationType getTableOperationType()

Description copied from interface: TableProcedureInterface

Given an operation type we can take decisions about what to do with pending operations. e.g. if we get a delete and we have some table operation pending (e.g. add column) we can abort those operations.

Specified by:

getTableOperationType in interface TableProcedureInterface

Specified by:

getTableOperationType in class AbstractStateMachineTableProcedure<CreateTableState>

Returns:

the operation type that the procedure is executing.

serializeStateData

protected void serializeStateData(ProcedureStateSerializer serializer)
                           throws java.io.IOException

Throws:

java.io.IOException

deserializeStateData

protected void deserializeStateData(ProcedureStateSerializer serializer)
                             throws java.io.IOException

Throws:

java.io.IOException

acquireLock

protected LockState acquireLock(MasterProcedureEnv env)

Overrides:

acquireLock in class AbstractStateMachineTableProcedure<CreateTableState>

createFsLayout

protected static java.util.List<RegionInfo> createFsLayout(MasterProcedureEnv env,
                                                           TableDescriptor tableDescriptor,
                                                           java.util.List<RegionInfo> newRegions)
                                                    throws java.io.IOException

Throws:

java.io.IOException

createFsLayout

protected static java.util.List<RegionInfo> createFsLayout(MasterProcedureEnv env,
                                                           TableDescriptor tableDescriptor,
                                                           java.util.List<RegionInfo> newRegions,
                                                           CreateTableProcedure.CreateHdfsRegions hdfsRegionHandler)
                                                    throws java.io.IOException

Throws:

java.io.IOException

moveTempDirectoryToHBaseRoot

protected static void moveTempDirectoryToHBaseRoot(MasterProcedureEnv env,
                                                   TableDescriptor tableDescriptor,
                                                   Path tempTableDir)
                                            throws java.io.IOException

Throws:

java.io.IOException

addTableToMeta

protected static java.util.List<RegionInfo> addTableToMeta(MasterProcedureEnv env,
                                                           TableDescriptor tableDescriptor,
                                                           java.util.List<RegionInfo> regions)
                                                    throws java.io.IOException

Throws:

java.io.IOException

setEnablingState

protected static void setEnablingState(MasterProcedureEnv env,
                                       TableName tableName)
                                throws java.io.IOException

Throws:

java.io.IOException

setEnabledState

protected static void setEnabledState(MasterProcedureEnv env,
                                      TableName tableName)
                               throws java.io.IOException

Throws:

java.io.IOException

updateTableDescCache

protected static void updateTableDescCache(MasterProcedureEnv env,
                                           TableName tableName)
                                    throws java.io.IOException

Throws:

java.io.IOException

shouldWaitClientAck

protected boolean shouldWaitClientAck(MasterProcedureEnv env)