Package org.apache.hadoop.hbase.regionserver

Class TestAtomicOperation

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestAtomicOperation

@Tag("org.apache.hadoop.hbase.testclassification.VerySlowRegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestAtomicOperation
extends Object

Testing of HRegion.incrementColumnValue, HRegion.increment, and HRegion.append

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestAtomicOperation.AtomicOperation
private class	TestAtomicOperation.CheckAndPutThread
static class	TestAtomicOperation.Incrementer	A thread that makes increment calls always on the same row, this.row against two column families on this row.
static class	TestAtomicOperation.MockHRegion
private class	TestAtomicOperation.PutThread
private static enum	TestAtomicOperation.TestStep

Field Summary

Fields

Modifier and Type	Field	Description
private final String	family
private static CountDownLatch	latch
private static final org.slf4j.Logger	LOG
private String	name
(package private) static final byte[]	qual1
(package private) static final byte[]	qual2
(package private) static final byte[]	qual3
(package private) org.apache.hadoop.hbase.regionserver.HRegion	region
(package private) static final byte[]	row
(package private) static final byte[]	row2
(package private) static byte[]	tableName
private HBaseTestingUtil	TEST_UTIL
private static TestAtomicOperation.TestStep	testStep
(package private) static final byte[]	value1
(package private) static final byte[]	value2

Constructor Summary

Constructors

Constructor	Description
TestAtomicOperation()

Method Summary

Modifier and Type	Method	Description
private void	assertICV(byte[] row, byte[] familiy, byte[] qualifier, long amount, boolean fast)
private void	initHRegion(byte[] tableName, String callingMethod, byte[]... families)
private void	initHRegion(byte[] tableName, String callingMethod, int[] maxVersions, byte[]... families)
void	setup(org.junit.jupiter.api.TestInfo testInfo)
void	teardown()
void	testAppend()	Test basic append operation.
void	testAppendMultiThreads()
void	testAppendWithMultipleFamilies()
void	testAppendWithNonExistingFamily()
void	testIncrementMultiThreads()	Test multi-threaded increments.
void	testIncrementWithNonExistingFamily()
void	testMultiRowMutationMultiThreads()	Test multi-threaded region mutations.
void	testPutAndCheckAndPutInParallel()	Test written as a verifier for HBASE-7051, CheckAndPut should properly read MVCC.
void	testRowMutationMultiThreads()	Test multi-threaded row mutations.

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

name

private String name

region

org.apache.hadoop.hbase.regionserver.HRegion region

TEST_UTIL

private HBaseTestingUtil TEST_UTIL

tableName

static byte[] tableName

qual1

static final byte[] qual1

qual2

static final byte[] qual2

qual3

static final byte[] qual3

value1

static final byte[] value1

value2

static final byte[] value2

row

static final byte[] row

row2

static final byte[] row2

latch

private static CountDownLatch latch

testStep

private static volatile TestAtomicOperation.TestStep testStep

family

private final String family

See Also:

• Constant Field Values

Constructor Details

TestAtomicOperation

public TestAtomicOperation()

Method Details

setup

@BeforeEach
public void setup(org.junit.jupiter.api.TestInfo testInfo)

teardown

@AfterEach
public void teardown()
              throws IOException

Throws:

IOException

testAppend

@Test
public void testAppend()
                throws IOException

Test basic append operation. More tests in FromClientSideTest5.testAppend().

Throws:

IOException

testAppendWithMultipleFamilies

@Test
public void testAppendWithMultipleFamilies()
                                    throws IOException

Throws:

IOException

testAppendWithNonExistingFamily

@Test
public void testAppendWithNonExistingFamily()
                                     throws IOException

Throws:

IOException

testIncrementWithNonExistingFamily

@Test
public void testIncrementWithNonExistingFamily()
                                        throws IOException

Throws:

IOException

testIncrementMultiThreads

@Test
public void testIncrementMultiThreads()
                               throws IOException

Test multi-threaded increments.

Throws:

IOException

assertICV

private void assertICV(byte[] row,
 byte[] familiy,
 byte[] qualifier,
 long amount,
 boolean fast)
                throws IOException

Throws:

IOException

initHRegion

private void initHRegion(byte[] tableName,
 String callingMethod,
 byte[]... families)
                  throws IOException

Throws:

IOException

initHRegion

private void initHRegion(byte[] tableName,
 String callingMethod,
 int[] maxVersions,
 byte[]... families)
                  throws IOException

Throws:

IOException

testAppendMultiThreads

@Test
public void testAppendMultiThreads()
                            throws IOException

Throws:

IOException

testRowMutationMultiThreads

@Test
public void testRowMutationMultiThreads()
                                 throws IOException

Test multi-threaded row mutations.

Throws:

IOException

testMultiRowMutationMultiThreads

@Test
public void testMultiRowMutationMultiThreads()
                                      throws IOException

Test multi-threaded region mutations.

Throws:

IOException

testPutAndCheckAndPutInParallel

@Test
public void testPutAndCheckAndPutInParallel()
                                     throws Exception

Test written as a verifier for HBASE-7051, CheckAndPut should properly read MVCC. Moved into TestAtomicOperation from its original location, TestHBase7051

Throws:

Exception