Package org.apache.hadoop.hbase

Class IntegrationTestIngestWithMOB

java.lang.Object

org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.IntegrationTestBase

org.apache.hadoop.hbase.IntegrationTestIngest

org.apache.hadoop.hbase.IntegrationTestIngestWithMOB

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

@Tag("org.apache.hadoop.hbase.testclassification.IntegrationTests")
public class IntegrationTestIngestWithMOB
extends IntegrationTestIngest

Integration Test for MOB ingest.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool

org.apache.hadoop.hbase.util.AbstractHBaseTool.OptionsOrderComparator

Field Summary

Fields

Modifier and Type	Field	Description
private static final char	COLON
private static final long	JUNIT_RUN_TIME
protected String[]	LOAD_TEST_TOOL_MOB_INIT_ARGS
static final String	MAX_MOB_DATA_SIZE
private int	maxMobDataSize
static final String	MIN_MOB_DATA_SIZE
private int	minMobDataSize
private byte[]	mobColumnFamily
private int	threshold
static final String	THRESHOLD

Fields inherited from class org.apache.hadoop.hbase.IntegrationTestIngest

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

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

Constructors

Constructor	Description
IntegrationTestIngestWithMOB()

Method Summary

Modifier and Type	Method	Description
protected void	addOptions()
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(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)
void	testIngest()

Methods inherited from class org.apache.hadoop.hbase.IntegrationTestIngest

getColumnFamilies, getMinServerCount, getNumKeys, getTablename, internalRunIngestTest, runIngestTest, runTestFromCommandLine, setUpCluster

Methods inherited from class org.apache.hadoop.hbase.IntegrationTestBase

cleanUp, cleanUpCluster, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, loadMonkeyProperties, processBaseOptions, 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

COLON

private static final char COLON

See Also:

• Constant Field Values

mobColumnFamily

private byte[] mobColumnFamily

THRESHOLD

public static final String THRESHOLD

See Also:

• Constant Field Values

MIN_MOB_DATA_SIZE

public static final String MIN_MOB_DATA_SIZE

See Also:

• Constant Field Values

MAX_MOB_DATA_SIZE

public static final String MAX_MOB_DATA_SIZE

See Also:

• Constant Field Values

threshold

private int threshold

minMobDataSize

private int minMobDataSize

maxMobDataSize

private int maxMobDataSize

JUNIT_RUN_TIME

private static final long JUNIT_RUN_TIME

See Also:

• Constant Field Values

LOAD_TEST_TOOL_MOB_INIT_ARGS

protected String[] LOAD_TEST_TOOL_MOB_INIT_ARGS

Constructor Details

IntegrationTestIngestWithMOB

public IntegrationTestIngestWithMOB()

Method Details

getArgsForLoadTestToolInitTable

protected String[] getArgsForLoadTestToolInitTable()

Overrides:

getArgsForLoadTestToolInitTable in class IntegrationTestIngest

addOptions

protected void addOptions()

Overrides:

addOptions in class IntegrationTestBase

processOptions

protected void processOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd)

Overrides:

processOptions in class IntegrationTestBase

testIngest

@Test
public void testIngest()
                throws Exception

Overrides:

testIngest in class IntegrationTestIngest

Throws:

Exception

initTable

protected void initTable()
                  throws IOException

Overrides:

initTable in class IntegrationTestIngest

Throws:

IOException

getArgsForLoadTestTool

protected String[] getArgsForLoadTestTool(String mode,
 String modeSpecificArg,
 long startKey,
 long numKeys)

Overrides:

getArgsForLoadTestTool in class IntegrationTestIngest

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception