public class IntegrationTestLoadAndVerify extends IntegrationTestBase
Modifier and Type | Class and Description |
---|---|
static class |
IntegrationTestLoadAndVerify.LoadMapper |
static class |
IntegrationTestLoadAndVerify.VerifyMapper |
static class |
IntegrationTestLoadAndVerify.VerifyReducer |
static class |
IntegrationTestLoadAndVerify.WALSearcher
Tool to search missing rows in WALs and hfiles.
|
CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp, util
cmdLineArgs, conf, EXIT_FAILURE, EXIT_SUCCESS
Constructor and Description |
---|
IntegrationTestLoadAndVerify() |
Modifier and Type | Method and Description |
---|---|
void |
cleanUpCluster() |
protected Job |
doLoad(Configuration conf,
HTableDescriptor htd) |
protected void |
doVerify(Configuration conf,
HTableDescriptor htd) |
protected java.util.Set<java.lang.String> |
getColumnFamilies() |
TableName |
getTablename() |
Path |
getTestDir(java.lang.String testName,
java.lang.String subdir) |
static void |
main(java.lang.String[] argv) |
protected void |
processOptions(CommandLine cmd)
This method is called to process the options after they have been parsed.
|
int |
runTestFromCommandLine() |
protected void |
setMapperClass(Job job) |
void |
setUpCluster() |
static long |
swapLong(long value)
Converts a "long" value between endian systems.
|
void |
testLoadAndVerify() |
void |
usage() |
addOptions, cleanUp, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, setUp, setUpMonkey, startMonkey
addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, parseArgs, parseInt, parseLong, printUsage, printUsage, run, setConf
public void setUpCluster() throws java.lang.Exception
setUpCluster
in class IntegrationTestBase
java.lang.Exception
public void cleanUpCluster() throws java.lang.Exception
cleanUpCluster
in class IntegrationTestBase
java.lang.Exception
public static long swapLong(long value)
value
- value to convertprotected Job doLoad(Configuration conf, HTableDescriptor htd) throws java.lang.Exception
java.lang.Exception
protected void setMapperClass(Job job)
protected void doVerify(Configuration conf, HTableDescriptor htd) throws java.lang.Exception
java.lang.Exception
public Path getTestDir(java.lang.String testName, java.lang.String subdir) throws java.io.IOException
java.io.IOException
public void testLoadAndVerify() throws java.lang.Exception
java.lang.Exception
public void usage()
protected void processOptions(CommandLine cmd)
AbstractHBaseTool
processOptions
in class IntegrationTestBase
public int runTestFromCommandLine() throws java.lang.Exception
runTestFromCommandLine
in class IntegrationTestBase
java.lang.Exception
public TableName getTablename()
getTablename
in class IntegrationTestBase
protected java.util.Set<java.lang.String> getColumnFamilies()
getColumnFamilies
in class IntegrationTestBase
public static void main(java.lang.String[] argv) throws java.lang.Exception
java.lang.Exception