Package org.apache.hadoop.hbase.client

Class TestAsyncTableNoncedRetry

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncTableNoncedRetry

public class TestAsyncTableNoncedRetry
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestAsyncTableNoncedRetry.SleepOnceCP

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.AsyncConnection	ASYNC_CONN
private static final AtomicInteger	CALLED
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	FAMILY
private static int	miniBatchOperationCount
private static final byte[]	QUALIFIER
private static final byte[]	QUALIFIER2
private static final byte[]	QUALIFIER3
private byte[]	row
private static final long	RPC_TIMEOUT
private static final long	SLEEP_TIME
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	TEST_UTIL
org.junit.rules.TestName	testName
private static final byte[]	VALUE

Constructor Summary

Constructors

Constructor	Description
TestAsyncTableNoncedRetry()

Method Summary

Modifier and Type	Method	Description
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testAppend()
void	testAppendInCheckAndMutate()
void	testAppendInRowMutations()
void	testAppendInRowMutationsInCheckAndMutate()
void	testAppendWhenReturnResultsEqualsFalse()
void	testBatch()
void	testIncrement()
void	testIncrementAndAppendInRowMutations()
void	testIncrementAndAppendInRowMutationsInCheckAndMutate()
void	testIncrementInCheckAndMutate()
void	testIncrementInRowMutations()
void	testIncrementInRowMutationsInCheckAndMutate()
void	testIncrementWhenReturnResultsEqualsFalse()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

private static final byte[] FAMILY

QUALIFIER

private static final byte[] QUALIFIER

QUALIFIER2

private static final byte[] QUALIFIER2

QUALIFIER3

private static final byte[] QUALIFIER3

VALUE

private static final byte[] VALUE

ASYNC_CONN

private static org.apache.hadoop.hbase.client.AsyncConnection ASYNC_CONN

testName

public org.junit.rules.TestName testName

row

private byte[] row

CALLED

private static final AtomicInteger CALLED

SLEEP_TIME

private static final long SLEEP_TIME

See Also:

• Constant Field Values

RPC_TIMEOUT

private static final long RPC_TIMEOUT

See Also:

• Constant Field Values

miniBatchOperationCount

private static int miniBatchOperationCount

Constructor Details

TestAsyncTableNoncedRetry

public TestAsyncTableNoncedRetry()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testAppend

public void testAppend()
                throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testAppendWhenReturnResultsEqualsFalse

public void testAppendWhenReturnResultsEqualsFalse()
                                            throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testIncrement

public void testIncrement()
                   throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testIncrementWhenReturnResultsEqualsFalse

public void testIncrementWhenReturnResultsEqualsFalse()
                                               throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testIncrementInRowMutations

public void testIncrementInRowMutations()
                                 throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testAppendInRowMutations

public void testAppendInRowMutations()
                              throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testIncrementAndAppendInRowMutations

public void testIncrementAndAppendInRowMutations()
                                          throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testIncrementInCheckAndMutate

public void testIncrementInCheckAndMutate()
                                   throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testAppendInCheckAndMutate

public void testAppendInCheckAndMutate()
                                throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testIncrementInRowMutationsInCheckAndMutate

public void testIncrementInRowMutationsInCheckAndMutate()
                                                 throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testAppendInRowMutationsInCheckAndMutate

public void testAppendInRowMutationsInCheckAndMutate()
                                              throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testIncrementAndAppendInRowMutationsInCheckAndMutate

public void testIncrementAndAppendInRowMutationsInCheckAndMutate()
                                                          throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testBatch

public void testBatch()
               throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException