Package org.apache.hadoop.hbase

Class AcidGuaranteesTestBase

java.lang.Object

org.apache.hadoop.hbase.AcidGuaranteesTestBase

Direct Known Subclasses:

TestAcidGuaranteesWithAdaptivePolicy, TestAcidGuaranteesWithBasicPolicy, TestAcidGuaranteesWithEagerPolicy, TestAcidGuaranteesWithNoInMemCompaction

public abstract class AcidGuaranteesTestBase
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)

Field Summary

Fields

Modifier and Type	Field	Description
private AcidGuaranteesTestTool	tool
private static final HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor	Description
AcidGuaranteesTestBase()

Method Summary

Modifier and Type	Method	Description
protected abstract org.apache.hadoop.hbase.MemoryCompactionPolicy	getMemoryCompactionPolicy()
private void	runTestAtomicity(long millisToRun, int numWriters, int numGetters, int numScanners, int numUniqueRows)
private void	runTestAtomicity(long millisToRun, int numWriters, int numGetters, int numScanners, int numUniqueRows, boolean useMob)
void	setUp()
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testGetAtomicity()
void	testMixedAtomicity()
void	testMobGetAtomicity()
void	testMobMixedAtomicity()
void	testMobScanAtomicity()
void	testScanAtomicity()

Methods inherited from class java.lang.Object

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

Field Details

UTIL

private static final HBaseTestingUtility UTIL

tool

private AcidGuaranteesTestTool tool

Constructor Details

AcidGuaranteesTestBase

public AcidGuaranteesTestBase()

Method Details

getMemoryCompactionPolicy

protected abstract org.apache.hadoop.hbase.MemoryCompactionPolicy getMemoryCompactionPolicy()

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

runTestAtomicity

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

Throws:

Exception

runTestAtomicity

private void runTestAtomicity(long millisToRun,
 int numWriters,
 int numGetters,
 int numScanners,
 int numUniqueRows,
 boolean useMob)
                       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

testMobGetAtomicity

public void testMobGetAtomicity()
                         throws Exception

Throws:

Exception

testMobScanAtomicity

public void testMobScanAtomicity()
                          throws Exception

Throws:

Exception

testMobMixedAtomicity

public void testMobMixedAtomicity()
                           throws Exception

Throws:

Exception