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, util
CHAOS_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, setUpCluster
cleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, setUp, setUpMonkey, startMonkey
public 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 IntegrationTestIngest
protected void addOptions()
addOptions
in class IntegrationTestBase
protected void processOptions(CommandLine cmd)
processOptions
in class IntegrationTestBase
public void testIngest() throws java.lang.Exception
testIngest
in class IntegrationTestIngest
java.lang.Exception
protected void initTable() throws java.io.IOException
initTable
in class IntegrationTestIngest
java.io.IOException
protected java.lang.String[] getArgsForLoadTestTool(java.lang.String mode, java.lang.String modeSpecificArg, long startKey, long numKeys)
getArgsForLoadTestTool
in class IntegrationTestIngest
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception