Package org.apache.hadoop.hbase
Class AcidGuaranteesTestTool
java.lang.Object
org.apache.hadoop.hbase.util.AbstractHBaseTool
org.apache.hadoop.hbase.AcidGuaranteesTestTool
- All Implemented Interfaces:
org.apache.hadoop.conf.Configurable,org.apache.hadoop.util.Tool
A test tool that uses multiple threads to read and write multifamily rows into a table, verifying
that reads never see partially-complete writes
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classThread that does single-row reads in a table, looking for partially completed rows.static classThread that does random full-row writes into a table.static classThread that does full scans of the table looking for any partially completed rows.Nested classes/interfaces inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool
org.apache.hadoop.hbase.util.AbstractHBaseTool.OptionsOrderComparator -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate booleanstatic final byte[][]static final byte[]static final byte[]static final byte[]private static final org.slf4j.Loggerprivate longstatic intprivate intprivate intprivate intprivate intstatic final byte[]private ExecutorServicestatic final org.apache.hadoop.hbase.TableNameprivate booleanFields 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 -
Method Summary
Modifier and TypeMethodDescriptionprotected voidprivate voidcreateTableIfMissing(org.apache.hadoop.hbase.client.Admin admin, boolean useMob) private ExecutorServiceprotected intdoWork()static voidprotected voidprocessOptions(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd) private voidrunTestAtomicity(org.apache.hadoop.hbase.client.Admin admin) Methods inherited from class org.apache.hadoop.hbase.util.AbstractHBaseTool
addOption, addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, addRequiredOption, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, getConf, getOptionAsDouble, getOptionAsInt, getOptionAsInt, getOptionAsLong, getOptionAsLong, newParser, parseArgs, parseInt, parseLong, printUsage, printUsage, processOldArgs, run, setConf
-
Field Details
-
LOG
-
TABLE_NAME
-
FAMILY_A
-
FAMILY_B
-
FAMILY_C
-
QUALIFIER_NAME
-
FAMILIES
-
NUM_COLS_TO_CHECK
-
millisToRun
-
numWriters
-
numGetters
-
numScanners
-
numUniqueRows
-
crazyFlush
-
useMob
-
-
Constructor Details
-
AcidGuaranteesTestTool
public AcidGuaranteesTestTool()
-
-
Method Details
-
createThreadPool
-
addOptions
- Specified by:
addOptionsin classorg.apache.hadoop.hbase.util.AbstractHBaseTool
-
processOptions
- Specified by:
processOptionsin classorg.apache.hadoop.hbase.util.AbstractHBaseTool
-
doWork
- Specified by:
doWorkin classorg.apache.hadoop.hbase.util.AbstractHBaseTool- Throws:
Exception
-
createTableIfMissing
private void createTableIfMissing(org.apache.hadoop.hbase.client.Admin admin, boolean useMob) throws IOException - Throws:
IOException
-
runTestAtomicity
- Throws:
Exception
-
main
-