public class IntegrationTestIngest extends IntegrationTestBase
LoadTestTool
to write and verify some data.Modifier and Type | Field and Description |
---|---|
protected HBaseCluster |
cluster |
protected static long |
DEFAULT_NUM_KEYS_PER_SERVER |
protected static int |
DEFAULT_NUM_READ_THREADS |
protected static int |
DEFAULT_NUM_WRITE_THREADS |
protected static long |
DEFAULT_RUN_TIME |
static char |
HIPHEN |
protected static long |
JUNIT_RUN_TIME |
protected java.lang.String[] |
LOAD_TEST_TOOL_INIT_ARGS |
protected LoadTestTool |
loadTool |
protected static Logger |
LOG |
protected static java.lang.String |
NUM_KEYS_PER_SERVER_KEY |
protected static java.lang.String |
NUM_READ_THREADS_KEY |
protected static java.lang.String |
NUM_WRITE_THREADS_KEY |
protected static java.lang.String |
RUN_TIME_KEY
A soft limit on how long we should run
|
protected IntegrationTestingUtility |
util |
CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp
Constructor and Description |
---|
IntegrationTestIngest() |
Modifier and Type | Method and Description |
---|---|
protected java.lang.String[] |
getArgsForLoadTestTool(java.lang.String mode,
java.lang.String modeSpecificArg,
long startKey,
long numKeys) |
protected java.lang.String[] |
getArgsForLoadTestToolInitTable() |
protected java.util.Set<java.lang.String> |
getColumnFamilies()
Provides the name of the CFs that are protected from random Chaos monkey activity (alter)
|
protected int |
getMinServerCount() |
protected long |
getNumKeys(long keysPerServer)
Estimates a data size based on the cluster size
|
TableName |
getTablename()
Provides the name of the table that is protected from random Chaos monkey activity
|
protected void |
initTable() |
protected void |
internalRunIngestTest(long runTime) |
static void |
main(java.lang.String[] args) |
protected void |
runIngestTest(long defaultRunTime,
long keysPerServerPerIter,
int colsPerKey,
int recordSize,
int writeThreads,
int readThreads) |
int |
runTestFromCommandLine() |
void |
setUpCluster() |
void |
testIngest() |
addOptions, cleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, processOptions, setUp, setUpMonkey, startMonkey
public static final char HIPHEN
protected static final long DEFAULT_RUN_TIME
protected static final long JUNIT_RUN_TIME
protected static final java.lang.String RUN_TIME_KEY
protected static final java.lang.String NUM_KEYS_PER_SERVER_KEY
protected static final long DEFAULT_NUM_KEYS_PER_SERVER
protected static final java.lang.String NUM_WRITE_THREADS_KEY
protected static final int DEFAULT_NUM_WRITE_THREADS
protected static final java.lang.String NUM_READ_THREADS_KEY
protected static final int DEFAULT_NUM_READ_THREADS
protected static final Logger LOG
protected IntegrationTestingUtility util
protected HBaseCluster cluster
protected LoadTestTool loadTool
protected java.lang.String[] LOAD_TEST_TOOL_INIT_ARGS
public void setUpCluster() throws java.lang.Exception
setUpCluster
in class IntegrationTestBase
java.lang.Exception
protected int getMinServerCount()
protected void initTable() throws java.io.IOException
java.io.IOException
public int runTestFromCommandLine() throws java.lang.Exception
runTestFromCommandLine
in class IntegrationTestBase
java.lang.Exception
public void testIngest() throws java.lang.Exception
java.lang.Exception
protected void internalRunIngestTest(long runTime) throws java.lang.Exception
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 runIngestTest(long defaultRunTime, long keysPerServerPerIter, int colsPerKey, int recordSize, int writeThreads, int readThreads) throws java.lang.Exception
java.lang.Exception
protected java.lang.String[] getArgsForLoadTestToolInitTable()
protected java.lang.String[] getArgsForLoadTestTool(java.lang.String mode, java.lang.String modeSpecificArg, long startKey, long numKeys)
protected long getNumKeys(long keysPerServer) throws java.io.IOException
java.io.IOException
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception