public class IntegrationTestIngestWithMOB extends IntegrationTestIngest
| Modifier and Type | Field and Description |
|---|---|
protected java.lang.String[] |
LOAD_TEST_TOOL_MOB_INIT_ARGS |
static java.lang.String |
MAX_MOB_DATA_SIZE |
static java.lang.String |
MIN_MOB_DATA_SIZE |
static java.lang.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, utilCHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp| Constructor and Description |
|---|
IntegrationTestIngestWithMOB() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
addOptions() |
protected java.lang.String[] |
getArgsForLoadTestTool(java.lang.String mode,
java.lang.String modeSpecificArg,
long startKey,
long numKeys) |
protected java.lang.String[] |
getArgsForLoadTestToolInitTable() |
protected void |
initTable() |
static void |
main(java.lang.String[] args) |
protected void |
processOptions(CommandLine cmd) |
void |
testIngest() |
getColumnFamilies, getMinServerCount, getNumKeys, getTablename, internalRunIngestTest, runIngestTest, runTestFromCommandLine, setUpClustercleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, setUp, setUpMonkey, startMonkeypublic static final java.lang.String THRESHOLD
public static final java.lang.String MIN_MOB_DATA_SIZE
public static final java.lang.String MAX_MOB_DATA_SIZE
protected java.lang.String[] LOAD_TEST_TOOL_MOB_INIT_ARGS
protected java.lang.String[] getArgsForLoadTestToolInitTable()
getArgsForLoadTestToolInitTable in class IntegrationTestIngestprotected void addOptions()
addOptions in class IntegrationTestBaseprotected void processOptions(CommandLine cmd)
processOptions in class IntegrationTestBasepublic void testIngest()
throws java.lang.Exception
testIngest in class IntegrationTestIngestjava.lang.Exceptionprotected void initTable()
throws java.io.IOException
initTable in class IntegrationTestIngestjava.io.IOExceptionprotected java.lang.String[] getArgsForLoadTestTool(java.lang.String mode,
java.lang.String modeSpecificArg,
long startKey,
long numKeys)
getArgsForLoadTestTool in class IntegrationTestIngestpublic static void main(java.lang.String[] args)
throws java.lang.Exception
java.lang.Exception