public class IntegrationTestIngestWithMOB extends IntegrationTestIngest
Modifier and Type | Field and Description |
---|---|
protected String[] |
LOAD_TEST_TOOL_MOB_INIT_ARGS |
static String |
MAX_MOB_DATA_SIZE |
static String |
MIN_MOB_DATA_SIZE |
static String |
THRESHOLD |
cluster, DEFAULT_NUM_KEYS_PER_SERVER, DEFAULT_NUM_READ_THREADS, DEFAULT_NUM_WRITE_THREADS, DEFAULT_RUN_TIME, HIPHEN, LOAD_TEST_TOOL_INIT_ARGS, loadTool, LOG, NUM_KEYS_PER_SERVER_KEY, NUM_READ_THREADS_KEY, NUM_WRITE_THREADS_KEY, RUN_TIME_KEY, util
CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp
cmdLineArgs, conf, EXIT_FAILURE, EXIT_SUCCESS
Constructor and Description |
---|
IntegrationTestIngestWithMOB() |
Modifier and Type | Method and Description |
---|---|
protected void |
addOptions()
Override this to add command-line options using
AbstractHBaseTool.addOptWithArg(java.lang.String, java.lang.String)
and similar methods. |
protected String[] |
getArgsForLoadTestTool(String mode,
String modeSpecificArg,
long startKey,
long numKeys) |
protected String[] |
getArgsForLoadTestToolInitTable() |
protected void |
initTable() |
static void |
main(String[] args) |
protected void |
processOptions(CommandLine cmd)
This method is called to process the options after they have been parsed.
|
void |
testIngest() |
getColumnFamilies, getMinServerCount, getNumKeys, getTablename, internalRunIngestTest, runIngestTest, runTestFromCommandLine, setUpCluster
cleanUp, cleanUpCluster, 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 static final String THRESHOLD
public static final String MIN_MOB_DATA_SIZE
public static final String MAX_MOB_DATA_SIZE
protected String[] LOAD_TEST_TOOL_MOB_INIT_ARGS
protected String[] getArgsForLoadTestToolInitTable()
getArgsForLoadTestToolInitTable
in class IntegrationTestIngest
protected void addOptions()
AbstractHBaseTool
AbstractHBaseTool.addOptWithArg(java.lang.String, java.lang.String)
and similar methods.addOptions
in class IntegrationTestBase
protected void processOptions(CommandLine cmd)
AbstractHBaseTool
processOptions
in class IntegrationTestBase
public void testIngest() throws Exception
testIngest
in class IntegrationTestIngest
Exception
protected void initTable() throws IOException
initTable
in class IntegrationTestIngest
IOException
protected String[] getArgsForLoadTestTool(String mode, String modeSpecificArg, long startKey, long numKeys)
getArgsForLoadTestTool
in class IntegrationTestIngest