org.apache.hadoop.hbase

Class TestAcidGuarantees

java.lang.Object

org.apache.hadoop.hbase.TestAcidGuarantees

public class TestAcidGuarantees
extends Object

Test case that uses multiple threads to read and write multifamily rows into a table, verifying that reads never see partially-complete writes. This can run as a junit test, or with a main() function which runs against a real cluster (eg for testing with failures, region movement, etc)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestAcidGuarantees.AtomicGetReader Thread that does single-row reads in a table, looking for partially completed rows.
static class	TestAcidGuarantees.AtomicityWriter Thread that does random full-row writes into a table.
static class	TestAcidGuarantees.AtomicScanReader Thread that does full scans of the table looking for any partially completed rows.

Field Summary

Fields

Modifier and Type	Field and Description
static byte[][]	FAMILIES
static byte[]	FAMILY_A
static byte[]	FAMILY_B
static byte[]	FAMILY_C
protected static Log	LOG
static int	NUM_COLS_TO_CHECK
static byte[]	QUALIFIER_NAME
static TableName	TABLE_NAME

Constructor Summary

Constructors

Constructor and Description
TestAcidGuarantees()

Method Summary

Modifier and Type	Method and Description
Configuration	getConf()
static void	main(String[] args)
int	run(String[] arg0)
void	runTestAtomicity(long millisToRun, int numWriters, int numGetters, int numScanners, int numUniqueRows)
void	runTestAtomicity(long millisToRun, int numWriters, int numGetters, int numScanners, int numUniqueRows, boolean systemTest)
void	setConf(Configuration c)
void	setHBaseTestingUtil(HBaseTestingUtility util)
void	testGetAtomicity()
void	testMixedAtomicity()
void	testScanAtomicity()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Log LOG

TABLE_NAME

public static final 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

Constructor Detail

TestAcidGuarantees

public TestAcidGuarantees()

Method Detail

setHBaseTestingUtil

public void setHBaseTestingUtil(HBaseTestingUtility util)

runTestAtomicity

public void runTestAtomicity(long millisToRun,
                             int numWriters,
                             int numGetters,
                             int numScanners,
                             int numUniqueRows)
                      throws Exception

Throws:

Exception

runTestAtomicity

public void runTestAtomicity(long millisToRun,
                             int numWriters,
                             int numGetters,
                             int numScanners,
                             int numUniqueRows,
                             boolean systemTest)
                      throws Exception

Throws:

Exception

testGetAtomicity

public void testGetAtomicity()
                      throws Exception

Throws:

Exception

testScanAtomicity

public void testScanAtomicity()
                       throws Exception

Throws:

Exception

testMixedAtomicity

public void testMixedAtomicity()
                        throws Exception

Throws:

Exception

getConf

public Configuration getConf()

setConf

public void setConf(Configuration c)

run

public int run(String[] arg0)
        throws Exception

Throws:

Exception

main

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

Throws:

Exception