org.apache.hadoop.hbase.regionserver

Class TestRegionIncrement

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionIncrement

public class TestRegionIncrement
extends java.lang.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.

Field Summary

Fields

Modifier and Type	Field and Description
TestName	name
TestRule	timeout

Constructor Summary

Constructors

Constructor and Description
TestRegionIncrement()

Method Summary

Modifier and Type	Method and Description
static java.util.Collection<java.lang.Object[]>	data()
void	tearDown()
void	testContendedAcrossCellsIncrement() Have each thread update its own Cell.
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

name

public TestName name

timeout

public final TestRule timeout

Constructor Detail

TestRegionIncrement

public TestRegionIncrement()

Method Detail

data

public static java.util.Collection<java.lang.Object[]> data()

tearDown

public void tearDown()
              throws java.lang.Exception

Throws:

java.lang.Exception

testUnContendedSingleCellIncrement

public void testUnContendedSingleCellIncrement()
                                        throws java.io.IOException,
                                               java.lang.InterruptedException

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

Throws:

java.io.IOException

java.lang.InterruptedException

testContendedAcrossCellsIncrement

public void testContendedAcrossCellsIncrement()
                                       throws java.io.IOException,
                                              java.lang.InterruptedException

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

Throws:

java.io.IOException

java.lang.InterruptedException