public class IntegrationTestBackupRestore extends IntegrationTestBase
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
BACKUP_ROOT_KEY |
protected static java.lang.String |
backupRoot |
protected static java.lang.String |
COLUMN_NAME |
protected static java.lang.String |
DEFAULT_BACKUP_ROOT |
protected static int |
DEFAULT_NUM_ITERATIONS |
protected static int |
DEFAULT_NUMBER_OF_TABLES |
protected static int |
DEFAULT_REGION_COUNT |
protected static int |
DEFAULT_REGIONSERVER_COUNT |
protected static int |
DEFAULT_ROWS_IN_ITERATION |
protected static java.lang.Object |
lock |
protected static Logger |
LOG |
protected static java.lang.String |
NUM_ITERATIONS_KEY |
protected static java.lang.String |
NUMBER_OF_TABLES_KEY |
protected static int |
numIterations |
protected static int |
numTables |
protected static java.lang.String |
REGION_COUNT_KEY |
protected static int |
regionsCountPerServer |
protected static java.lang.String |
REGIONSERVER_COUNT_KEY |
protected static int |
regionServerCount |
protected static java.lang.String |
ROWS_PER_ITERATION_KEY |
protected static int |
rowsInIteration |
protected static long |
SLEEP_TIME_DEFAULT |
protected static java.lang.String |
SLEEP_TIME_KEY |
protected long |
sleepTime |
protected static TableName[] |
tableNames |
CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp, util
Constructor and Description |
---|
IntegrationTestBackupRestore() |
Modifier and Type | Method and Description |
---|---|
protected void |
addOptions() |
protected boolean |
checkSucceeded(java.lang.String backupId) |
RestoreRequest |
createRestoreRequest(java.lang.String backupRootDir,
java.lang.String backupId,
boolean check,
TableName[] fromTables,
TableName[] toTables,
boolean isOverwrite)
Get restore request.
|
protected java.util.Set<java.lang.String> |
getColumnFamilies()
Provides the name of the CFs that are protected from random Chaos monkey activity (alter)
|
TableName |
getTablename()
Provides the name of the table that is protected from random Chaos monkey activity
|
static void |
main(java.lang.String[] args) |
protected void |
processOptions(CommandLine cmd) |
int |
runTestFromCommandLine() |
void |
setUp() |
void |
setUpCluster() |
void |
setUpMonkey() |
void |
tearDown() |
void |
testBackupRestore() |
cleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, startMonkey
protected static final Logger LOG
protected static final java.lang.String NUMBER_OF_TABLES_KEY
protected static final java.lang.String COLUMN_NAME
protected static final java.lang.String REGION_COUNT_KEY
protected static final java.lang.String REGIONSERVER_COUNT_KEY
protected static final java.lang.String ROWS_PER_ITERATION_KEY
protected static final java.lang.String NUM_ITERATIONS_KEY
protected static final java.lang.String BACKUP_ROOT_KEY
protected static final int DEFAULT_REGION_COUNT
protected static final int DEFAULT_REGIONSERVER_COUNT
protected static final int DEFAULT_NUMBER_OF_TABLES
protected static final int DEFAULT_NUM_ITERATIONS
protected static final int DEFAULT_ROWS_IN_ITERATION
protected static java.lang.String DEFAULT_BACKUP_ROOT
protected static final java.lang.String SLEEP_TIME_KEY
protected static final long SLEEP_TIME_DEFAULT
protected static int rowsInIteration
protected static int regionsCountPerServer
protected static int regionServerCount
protected static int numIterations
protected static int numTables
protected static java.lang.String backupRoot
protected static TableName[] tableNames
protected long sleepTime
protected static java.lang.Object lock
public void setUp() throws java.lang.Exception
setUp
in class IntegrationTestBase
java.lang.Exception
public void tearDown() throws java.io.IOException
java.io.IOException
public void setUpMonkey() throws java.lang.Exception
setUpMonkey
in class IntegrationTestBase
java.lang.Exception
public void testBackupRestore() throws java.lang.Exception
java.lang.Exception
protected boolean checkSucceeded(java.lang.String backupId) throws java.io.IOException
backupId
- pass backup ID to check status ofjava.io.IOException
public RestoreRequest createRestoreRequest(java.lang.String backupRootDir, java.lang.String backupId, boolean check, TableName[] fromTables, TableName[] toTables, boolean isOverwrite)
backupRootDir
- directory where backup is locatedbackupId
- backup IDcheck
- check the backupfromTables
- table names to restore fromtoTables
- new table names to restore toisOverwrite
- overwrite the table(s)public void setUpCluster() throws java.lang.Exception
setUpCluster
in class IntegrationTestBase
java.lang.Exception
public int runTestFromCommandLine() throws java.lang.Exception
runTestFromCommandLine
in class IntegrationTestBase
java.lang.Exception
public TableName getTablename()
IntegrationTestBase
getTablename
in class IntegrationTestBase
protected java.util.Set<java.lang.String> getColumnFamilies()
IntegrationTestBase
getColumnFamilies
in class IntegrationTestBase
protected void addOptions()
addOptions
in class IntegrationTestBase
protected void processOptions(CommandLine cmd)
processOptions
in class IntegrationTestBase
public static void main(java.lang.String[] args) throws java.lang.Exception
args
- argument listjava.lang.Exception