Package org.apache.hadoop.hbase.client

Class TestAsyncTableNoncedRetry

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncTableNoncedRetry

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
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
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
private static final byte[]	VALUE

Constructor Summary

Constructors

Constructor	Description
TestAsyncTableNoncedRetry()

Method Summary

Modifier and Type	Method	Description
void	setUp(org.junit.jupiter.api.TestInfo info)
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

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

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

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo info)
           throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testAppend

@Test
public void testAppend()
                throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testAppendWhenReturnResultsEqualsFalse

@Test
public void testAppendWhenReturnResultsEqualsFalse()
                                            throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testIncrement

@Test
public void testIncrement()
                   throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testIncrementWhenReturnResultsEqualsFalse

@Test
public void testIncrementWhenReturnResultsEqualsFalse()
                                               throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testIncrementInRowMutations

@Test
public void testIncrementInRowMutations()
                                 throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testAppendInRowMutations

@Test
public void testAppendInRowMutations()
                              throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testIncrementAndAppendInRowMutations

@Test
public void testIncrementAndAppendInRowMutations()
                                          throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testIncrementInCheckAndMutate

@Test
public void testIncrementInCheckAndMutate()
                                   throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testAppendInCheckAndMutate

@Test
public void testAppendInCheckAndMutate()
                                throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testIncrementInRowMutationsInCheckAndMutate

@Test
public void testIncrementInRowMutationsInCheckAndMutate()
                                                 throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testAppendInRowMutationsInCheckAndMutate

@Test
public void testAppendInRowMutationsInCheckAndMutate()
                                              throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testIncrementAndAppendInRowMutationsInCheckAndMutate

@Test
public void testIncrementAndAppendInRowMutationsInCheckAndMutate()
                                                          throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testBatch

@Test
public void testBatch()
               throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException