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

@InterfaceAudience.Private
public class AcidGuaranteesTestTool
extends org.apache.hadoop.hbase.util.AbstractHBaseTool

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 Classes

Modifier and Type	Class and Description
static class	AcidGuaranteesTestTool.AtomicGetReader Thread that does single-row reads in a table, looking for partially completed rows.
static class	AcidGuaranteesTestTool.AtomicityWriter Thread that does random full-row writes into a table.
static class	AcidGuaranteesTestTool.AtomicScanReader 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

Fields

Modifier and Type	Field and Description
private boolean	crazyFlush
static byte[][]	FAMILIES
static byte[]	FAMILY_A
static byte[]	FAMILY_B
static byte[]	FAMILY_C
private static org.slf4j.Logger	LOG
private long	millisToRun
static int	NUM_COLS_TO_CHECK
private int	numGetters
private int	numScanners
private int	numUniqueRows
private int	numWriters
static byte[]	QUALIFIER_NAME
private ExecutorService	sharedPool
static org.apache.hadoop.hbase.TableName	TABLE_NAME
private boolean	useMob

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 and Description
AcidGuaranteesTestTool()

Method Summary

Modifier and Type	Method and Description
protected void	addOptions()
private void	createTableIfMissing(org.apache.hadoop.hbase.client.Admin admin, boolean useMob)
private ExecutorService	createThreadPool()
protected int	doWork()
static void	main(String[] args)
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, 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 Detail

LOG

private static final org.slf4j.Logger LOG

TABLE_NAME

public static final org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY_A

public static final byte[] FAMILY_A

FAMILY_B

public static final byte[] FAMILY_B

FAMILY_C

public static final byte[] FAMILY_C

QUALIFIER_NAME

public static final byte[] QUALIFIER_NAME

FAMILIES

public static final byte[][] FAMILIES

NUM_COLS_TO_CHECK

public static int NUM_COLS_TO_CHECK

sharedPool

private ExecutorService sharedPool

millisToRun

private long millisToRun

numWriters

private int numWriters

numGetters

private int numGetters

numScanners

private int numScanners

numUniqueRows

private int numUniqueRows

crazyFlush

private boolean crazyFlush

useMob

private boolean useMob

Constructor Detail

AcidGuaranteesTestTool

public AcidGuaranteesTestTool()

Method Detail

createThreadPool

private ExecutorService createThreadPool()

addOptions

protected void addOptions()

Specified by:

addOptions in class org.apache.hadoop.hbase.util.AbstractHBaseTool

processOptions

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

Specified by:

processOptions in class org.apache.hadoop.hbase.util.AbstractHBaseTool

doWork

protected int doWork()
              throws Exception

Specified by:

doWork in class org.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

private void runTestAtomicity(org.apache.hadoop.hbase.client.Admin admin)
                       throws Exception

Throws:

Exception

main

public static void main(String[] args)