org.apache.hadoop.hbase.master.procedure

Class MasterProcedureTestingUtility

java.lang.Object

org.apache.hadoop.hbase.master.procedure.MasterProcedureTestingUtility

public class MasterProcedureTestingUtility
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MasterProcedureTestingUtility.InjectAbortOnLoadListener

Method Summary

Modifier and Type	Method and Description
static HTableDescriptor	createHTD(TableName tableName, String... family)
static HRegionInfo[]	createTable(ProcedureExecutor<MasterProcedureEnv> procExec, TableName tableName, byte[][] splitKeys, String... family)
static long	generateNonce(HMaster master)
static long	generateNonceGroup(HMaster master)
static void	loadData(Connection connection, TableName tableName, int rows, byte[][] splitKeys, String... sfamilies)
static <TState> void	testRecoveryAndDoubleExecution(ProcedureExecutor<MasterProcedureEnv> procExec, long procId, int numSteps, TState[] states)
static <TState> void	testRollbackAndDoubleExecution(ProcedureExecutor<MasterProcedureEnv> procExec, long procId, int lastStep, TState[] states)
static <TState> void	testRollbackAndDoubleExecutionAfterPONR(ProcedureExecutor<MasterProcedureEnv> procExec, long procId, int lastStep, TState[] states)
static <TState> void	testRollbackRetriableFailure(ProcedureExecutor<MasterProcedureEnv> procExec, long procId, int lastStep, TState[] states)
static void	validateColumnFamilyAddition(HMaster master, TableName tableName, String family)
static void	validateColumnFamilyDeletion(HMaster master, TableName tableName, String family)
static void	validateColumnFamilyModification(HMaster master, TableName tableName, String family, HColumnDescriptor columnDescriptor)
static void	validateTableCreation(HMaster master, TableName tableName, HRegionInfo[] regions, boolean hasFamilyDirs, String... family)
static void	validateTableCreation(HMaster master, TableName tableName, HRegionInfo[] regions, String... family)
static void	validateTableDeletion(HMaster master, TableName tableName, HRegionInfo[] regions, String... family)
static void	validateTableIsDisabled(HMaster master, TableName tableName)
static void	validateTableIsEnabled(HMaster master, TableName tableName)

Methods inherited from class java.lang.Object

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

Method Detail

createHTD

public static HTableDescriptor createHTD(TableName tableName,
                                         String... family)

createTable

public static HRegionInfo[] createTable(ProcedureExecutor<MasterProcedureEnv> procExec,
                                        TableName tableName,
                                        byte[][] splitKeys,
                                        String... family)
                                 throws IOException

Throws:

IOException

validateTableCreation

public static void validateTableCreation(HMaster master,
                                         TableName tableName,
                                         HRegionInfo[] regions,
                                         String... family)
                                  throws IOException

Throws:

IOException

validateTableCreation

public static void validateTableCreation(HMaster master,
                                         TableName tableName,
                                         HRegionInfo[] regions,
                                         boolean hasFamilyDirs,
                                         String... family)
                                  throws IOException

Throws:

IOException

validateTableDeletion

public static void validateTableDeletion(HMaster master,
                                         TableName tableName,
                                         HRegionInfo[] regions,
                                         String... family)
                                  throws IOException

Throws:

IOException

validateTableIsEnabled

public static void validateTableIsEnabled(HMaster master,
                                          TableName tableName)
                                   throws IOException

Throws:

IOException

validateTableIsDisabled

public static void validateTableIsDisabled(HMaster master,
                                           TableName tableName)
                                    throws IOException

Throws:

IOException

testRecoveryAndDoubleExecution

public static <TState> void testRecoveryAndDoubleExecution(ProcedureExecutor<MasterProcedureEnv> procExec,
                                                           long procId,
                                                           int numSteps,
                                                           TState[] states)
                                                    throws Exception

Throws:

Exception

testRollbackAndDoubleExecution

public static <TState> void testRollbackAndDoubleExecution(ProcedureExecutor<MasterProcedureEnv> procExec,
                                                           long procId,
                                                           int lastStep,
                                                           TState[] states)
                                                    throws Exception

Throws:

Exception

testRollbackAndDoubleExecutionAfterPONR

public static <TState> void testRollbackAndDoubleExecutionAfterPONR(ProcedureExecutor<MasterProcedureEnv> procExec,
                                                                    long procId,
                                                                    int lastStep,
                                                                    TState[] states)
                                                             throws Exception

Throws:

Exception

testRollbackRetriableFailure

public static <TState> void testRollbackRetriableFailure(ProcedureExecutor<MasterProcedureEnv> procExec,
                                                         long procId,
                                                         int lastStep,
                                                         TState[] states)
                                                  throws Exception

Throws:

Exception

validateColumnFamilyAddition

public static void validateColumnFamilyAddition(HMaster master,
                                                TableName tableName,
                                                String family)
                                         throws IOException

Throws:

IOException

validateColumnFamilyDeletion

public static void validateColumnFamilyDeletion(HMaster master,
                                                TableName tableName,
                                                String family)
                                         throws IOException

Throws:

IOException

validateColumnFamilyModification

public static void validateColumnFamilyModification(HMaster master,
                                                    TableName tableName,
                                                    String family,
                                                    HColumnDescriptor columnDescriptor)
                                             throws IOException

Throws:

IOException

loadData

public static void loadData(Connection connection,
                            TableName tableName,
                            int rows,
                            byte[][] splitKeys,
                            String... sfamilies)
                     throws IOException

Throws:

IOException

generateNonceGroup

public static long generateNonceGroup(HMaster master)

generateNonce

public static long generateNonce(HMaster master)