Package org.apache.hadoop.hbase
Class IntegrationTestIngest
java.lang.Object
org.apache.hadoop.hbase.util.AbstractHBaseTool
org.apache.hadoop.hbase.IntegrationTestBase
org.apache.hadoop.hbase.IntegrationTestIngest
- All Implemented Interfaces:
org.apache.hadoop.conf.Configurable
,org.apache.hadoop.util.Tool
- Direct Known Subclasses:
IntegrationTestIngestStripeCompactions
,IntegrationTestIngestWithACL
,IntegrationTestIngestWithEncryption
,IntegrationTestIngestWithMOB
,IntegrationTestIngestWithTags
,IntegrationTestIngestWithVisibilityLabels
,IntegrationTestRegionReplicaReplication
,IntegrationTestTimeBoundedRequestsWithRegionReplicas
A base class for tests that do something with the cluster while running
LoadTestTool
to
write and verify some data.-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool
org.apache.hadoop.hbase.util.AbstractHBaseTool.OptionsOrderComparator
-
Field Summary
Modifier and TypeFieldDescriptionprotected HBaseClusterInterface
protected static final long
protected static final int
protected static final int
protected static final long
static final char
protected static final long
protected String[]
protected org.apache.hadoop.hbase.util.LoadTestTool
protected static final org.slf4j.Logger
protected static final String
protected static final String
protected static final String
protected static final String
A soft limit on how long we should runprivate static final int
Fields inherited from class org.apache.hadoop.hbase.IntegrationTestBase
CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp, util
Fields inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool
cmdLineArgs, conf, EXIT_FAILURE, EXIT_SUCCESS, LONG_HELP_OPTION, options, SHORT_HELP_OPTION
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprivate void
protected String[]
getArgsForLoadTestTool
(String mode, String modeSpecificArg, long startKey, long numKeys) protected String[]
Provides the name of the CFs that are protected from random Chaos monkey activity (alter)private String
protected int
protected long
getNumKeys
(long keysPerServer) Estimates a data size based on the cluster sizeorg.apache.hadoop.hbase.TableName
Provides the name of the table that is protected from random Chaos monkey activityprotected void
protected void
internalRunIngestTest
(long runTime) static void
protected void
runIngestTest
(long defaultRunTime, long keysPerServerPerIter, int colsPerKey, int recordSize, int writeThreads, int readThreads) int
void
void
Methods inherited from class org.apache.hadoop.hbase.IntegrationTestBase
addOptions, cleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, loadMonkeyProperties, processBaseOptions, processOptions, setUp, setUpMonkey, startMonkey
Methods inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool
addOption, addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOption, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, getOptionAsDouble, getOptionAsInt, getOptionAsInt, getOptionAsLong, getOptionAsLong, newParser, parseArgs, parseInt, parseLong, printUsage, printUsage, processOldArgs, run, setConf
-
Field Details
-
HIPHEN
- See Also:
-
SERVER_COUNT
- See Also:
-
DEFAULT_RUN_TIME
- See Also:
-
JUNIT_RUN_TIME
- See Also:
-
RUN_TIME_KEY
A soft limit on how long we should run- See Also:
-
NUM_KEYS_PER_SERVER_KEY
- See Also:
-
DEFAULT_NUM_KEYS_PER_SERVER
- See Also:
-
NUM_WRITE_THREADS_KEY
- See Also:
-
DEFAULT_NUM_WRITE_THREADS
- See Also:
-
NUM_READ_THREADS_KEY
- See Also:
-
DEFAULT_NUM_READ_THREADS
- See Also:
-
LOG
-
cluster
-
loadTool
-
LOAD_TEST_TOOL_INIT_ARGS
-
-
Constructor Details
-
IntegrationTestIngest
public IntegrationTestIngest()
-
-
Method Details
-
setUpCluster
- Specified by:
setUpCluster
in classIntegrationTestBase
- Throws:
Exception
-
getMinServerCount
-
initTable
- Throws:
IOException
-
runTestFromCommandLine
- Specified by:
runTestFromCommandLine
in classIntegrationTestBase
- Throws:
Exception
-
testIngest
- Throws:
Exception
-
internalRunIngestTest
- Throws:
Exception
-
getTablename
Description copied from class:IntegrationTestBase
Provides the name of the table that is protected from random Chaos monkey activity- Specified by:
getTablename
in classIntegrationTestBase
- Returns:
- table to not delete.
-
getColumnFamilies
Description copied from class:IntegrationTestBase
Provides the name of the CFs that are protected from random Chaos monkey activity (alter)- Specified by:
getColumnFamilies
in classIntegrationTestBase
- Returns:
- set of cf names to protect.
-
deleteTableIfNecessary
- Throws:
IOException
-
runIngestTest
protected void runIngestTest(long defaultRunTime, long keysPerServerPerIter, int colsPerKey, int recordSize, int writeThreads, int readThreads) throws Exception - Throws:
Exception
-
getArgsForLoadTestToolInitTable
-
getArgsForLoadTestTool
protected String[] getArgsForLoadTestTool(String mode, String modeSpecificArg, long startKey, long numKeys) -
getColumnFamiliesAsString
-
getNumKeys
Estimates a data size based on the cluster size- Throws:
IOException
-
main
- Throws:
Exception
-