org.apache.hadoop.hbase.regionserver

Class TestRegionIncrement

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionIncrement

public class TestRegionIncrement
extends Object

Increments with some concurrency against a region to ensure we get the right answer. Test is parameterized to run the fast and slow path increments; if fast, HRegion.INCREMENT_FAST_BUT_NARROW_CONSISTENCY_KEY is true.

There is similar test up in TestAtomicOperation. It does a test where it has 100 threads doing increments across two column families all on one row and the increments are connected to prove atomicity on row.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestRegionIncrement.CrossRowCellIncrementer Increments a random row's Cell count times.
private static class	TestRegionIncrement.SingleCellIncrementer Increments a single cell a bunch of times.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static byte[]	INCREMENT_BYTES
private static int	INCREMENT_COUNT
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static HBaseTestingUtility	TEST_UTIL
private static int	THREAD_COUNT

Constructor Summary

Constructors

Constructor and Description
TestRegionIncrement()

Method Summary

Modifier and Type	Method and Description
private void	closeRegion(org.apache.hadoop.hbase.regionserver.HRegion region)
private org.apache.hadoop.hbase.regionserver.HRegion	getRegion(org.apache.hadoop.conf.Configuration conf, String tableName)
void	setUp()
void	tearDown()
void	testContendedAcrossCellsIncrement() Have each thread update its own Cell.
void	testMVCCCausingMisRead()
void	testUnContendedSingleCellIncrement() Have each thread update its own Cell.

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

name

public org.junit.rules.TestName name

TEST_UTIL

private static HBaseTestingUtility TEST_UTIL

INCREMENT_BYTES

private static final byte[] INCREMENT_BYTES

THREAD_COUNT

private static final int THREAD_COUNT

See Also:

Constant Field Values

INCREMENT_COUNT

private static final int INCREMENT_COUNT

See Also:

Constant Field Values

Constructor Detail

TestRegionIncrement

public TestRegionIncrement()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

getRegion

private org.apache.hadoop.hbase.regionserver.HRegion getRegion(org.apache.hadoop.conf.Configuration conf,
                                                               String tableName)
                                                        throws IOException

Throws:

IOException

closeRegion

private void closeRegion(org.apache.hadoop.hbase.regionserver.HRegion region)
                  throws IOException

Throws:

IOException

testMVCCCausingMisRead

public void testMVCCCausingMisRead()
                            throws IOException

Throws:

IOException

testUnContendedSingleCellIncrement

public void testUnContendedSingleCellIncrement()
                                        throws IOException,
                                               InterruptedException

Have each thread update its own Cell. Avoid contention with another thread.

Throws:

IOException

InterruptedException

testContendedAcrossCellsIncrement

public void testContendedAcrossCellsIncrement()
                                       throws IOException,
                                              InterruptedException

Have each thread update its own Cell. Avoid contention with another thread. This is

Throws:

IOException

InterruptedException