public class MasterProcedureTestingUtility
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
MasterProcedureTestingUtility.InjectAbortOnLoadListener |
Modifier and Type | Method and Description |
---|---|
static HTableDescriptor |
createHTD(TableName tableName,
java.lang.String... family) |
static HRegionInfo[] |
createTable(ProcedureExecutor<MasterProcedureEnv> procExec,
TableName tableName,
byte[][] splitKeys,
java.lang.String... family) |
static long |
generateNonce(HMaster master) |
static long |
generateNonceGroup(HMaster master) |
static void |
loadData(Connection connection,
TableName tableName,
int rows,
byte[][] splitKeys,
java.lang.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,
java.lang.String family) |
static void |
validateColumnFamilyDeletion(HMaster master,
TableName tableName,
java.lang.String family) |
static void |
validateColumnFamilyModification(HMaster master,
TableName tableName,
java.lang.String family,
HColumnDescriptor columnDescriptor) |
static void |
validateTableCreation(HMaster master,
TableName tableName,
HRegionInfo[] regions,
boolean hasFamilyDirs,
java.lang.String... family) |
static void |
validateTableCreation(HMaster master,
TableName tableName,
HRegionInfo[] regions,
java.lang.String... family) |
static void |
validateTableDeletion(HMaster master,
TableName tableName,
HRegionInfo[] regions,
java.lang.String... family) |
static void |
validateTableIsDisabled(HMaster master,
TableName tableName) |
static void |
validateTableIsEnabled(HMaster master,
TableName tableName) |
public static HTableDescriptor createHTD(TableName tableName, java.lang.String... family)
public static HRegionInfo[] createTable(ProcedureExecutor<MasterProcedureEnv> procExec, TableName tableName, byte[][] splitKeys, java.lang.String... family) throws java.io.IOException
java.io.IOException
public static void validateTableCreation(HMaster master, TableName tableName, HRegionInfo[] regions, java.lang.String... family) throws java.io.IOException
java.io.IOException
public static void validateTableCreation(HMaster master, TableName tableName, HRegionInfo[] regions, boolean hasFamilyDirs, java.lang.String... family) throws java.io.IOException
java.io.IOException
public static void validateTableDeletion(HMaster master, TableName tableName, HRegionInfo[] regions, java.lang.String... family) throws java.io.IOException
java.io.IOException
public static void validateTableIsEnabled(HMaster master, TableName tableName) throws java.io.IOException
java.io.IOException
public static void validateTableIsDisabled(HMaster master, TableName tableName) throws java.io.IOException
java.io.IOException
public static <TState> void testRecoveryAndDoubleExecution(ProcedureExecutor<MasterProcedureEnv> procExec, long procId, int numSteps, TState[] states) throws java.lang.Exception
java.lang.Exception
public static <TState> void testRollbackAndDoubleExecution(ProcedureExecutor<MasterProcedureEnv> procExec, long procId, int lastStep, TState[] states) throws java.lang.Exception
java.lang.Exception
public static <TState> void testRollbackAndDoubleExecutionAfterPONR(ProcedureExecutor<MasterProcedureEnv> procExec, long procId, int lastStep, TState[] states) throws java.lang.Exception
java.lang.Exception
public static <TState> void testRollbackRetriableFailure(ProcedureExecutor<MasterProcedureEnv> procExec, long procId, int lastStep, TState[] states) throws java.lang.Exception
java.lang.Exception
public static void validateColumnFamilyAddition(HMaster master, TableName tableName, java.lang.String family) throws java.io.IOException
java.io.IOException
public static void validateColumnFamilyDeletion(HMaster master, TableName tableName, java.lang.String family) throws java.io.IOException
java.io.IOException
public static void validateColumnFamilyModification(HMaster master, TableName tableName, java.lang.String family, HColumnDescriptor columnDescriptor) throws java.io.IOException
java.io.IOException
public static void loadData(Connection connection, TableName tableName, int rows, byte[][] splitKeys, java.lang.String... sfamilies) throws java.io.IOException
java.io.IOException
public static long generateNonceGroup(HMaster master)
public static long generateNonce(HMaster master)