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
Modifier and TypeClassDescriptionstatic class
Thread that does single-row reads in a table, looking for partially completed rows.static class
Thread that does random full-row writes into a table.static class
Thread 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
Modifier and TypeFieldDescriptionprivate boolean
static final byte[][]
static final byte[]
static final byte[]
static final byte[]
private static final org.slf4j.Logger
private long
static int
private int
private int
private int
private int
static final byte[]
private ExecutorService
static final org.apache.hadoop.hbase.TableName
private boolean
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 TypeMethodDescriptionprotected void
private void
createTableIfMissing
(org.apache.hadoop.hbase.client.Admin admin, boolean useMob) private ExecutorService
protected int
doWork()
static void
protected void
processOptions
(org.apache.hbase.thirdparty.org.apache.commons.cli.CommandLine cmd) private void
runTestAtomicity
(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:
addOptions
in classorg.apache.hadoop.hbase.util.AbstractHBaseTool
-
processOptions
- Specified by:
processOptions
in classorg.apache.hadoop.hbase.util.AbstractHBaseTool
-
doWork
- Specified by:
doWork
in 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
-