Package org.apache.hadoop.hbase.client

Class TestAsyncTableBatch

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncTableBatch

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestAsyncTableBatch.ErrorInjectObserver

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.AsyncConnection	CONN
private static int	COUNT
private static byte[]	CQ
private static byte[]	CQ1
private static byte[]	FAMILY
private static int	MAX_KEY_VALUE_SIZE
private static byte[][]	SPLIT_KEYS
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private final Function<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.client.AsyncTable<?>>	tableGetter
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestAsyncTableBatch(String tableType, Function<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.client.AsyncTable<?>> tableGetter)

Method Summary

Modifier and Type	Method	Description
private static org.apache.hadoop.hbase.client.AsyncTable<?>	getRawTable(org.apache.hadoop.hbase.TableName tableName)
private byte[]	getRow(int i)
private static org.apache.hadoop.hbase.client.AsyncTable<?>	getTable(org.apache.hadoop.hbase.TableName tableName)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
static void	setUp()
void	setUpBeforeTest()
static void	tearDown()
void	tearDownAfterTest()
void	test()
void	testInvalidMutation()
void	testInvalidMutationInRowMutations()
void	testInvalidMutationInRowMutationsInCheckAndMutate()
void	testMixed()
void	testPartialSuccess()
void	testPartialSuccessOnSameRegion()
void	testWithCheckAndMutate()
void	testWithRegionServerFailover()

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 org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

private static byte[] FAMILY

CQ

private static byte[] CQ

CQ1

private static byte[] CQ1

COUNT

private static int COUNT

CONN

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

SPLIT_KEYS

private static byte[][] SPLIT_KEYS

MAX_KEY_VALUE_SIZE

private static int MAX_KEY_VALUE_SIZE

tableGetter

private final Function<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.client.AsyncTable<?>> tableGetter

Constructor Details

TestAsyncTableBatch

public TestAsyncTableBatch(String tableType,
 Function<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.client.AsyncTable<?>> tableGetter)

Method Details

getRawTable

private static org.apache.hadoop.hbase.client.AsyncTable<?> getRawTable(org.apache.hadoop.hbase.TableName tableName)

getTable

private static org.apache.hadoop.hbase.client.AsyncTable<?> getTable(org.apache.hadoop.hbase.TableName tableName)

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

setUpBeforeTest

@BeforeEach
public void setUpBeforeTest()
                     throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

tearDownAfterTest

@AfterEach
public void tearDownAfterTest()
                       throws IOException

Throws:

IOException

getRow

private byte[] getRow(int i)

test

@TestTemplate
public void test()
          throws InterruptedException,
ExecutionException,
IOException,
TimeoutException

Throws:

InterruptedException

ExecutionException

IOException

TimeoutException

testWithRegionServerFailover

@TestTemplate
public void testWithRegionServerFailover()
                                  throws Exception

Throws:

Exception

testMixed

@TestTemplate
public void testMixed()
               throws InterruptedException,
ExecutionException,
IOException

Throws:

InterruptedException

ExecutionException

IOException

testPartialSuccess

@TestTemplate
public void testPartialSuccess()
                        throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testPartialSuccessOnSameRegion

@TestTemplate
public void testPartialSuccessOnSameRegion()
                                    throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testInvalidMutation

@TestTemplate
public void testInvalidMutation()

testInvalidMutationInRowMutations

@TestTemplate
public void testInvalidMutationInRowMutations()
                                       throws IOException

Throws:

IOException

testInvalidMutationInRowMutationsInCheckAndMutate

@TestTemplate
public void testInvalidMutationInRowMutationsInCheckAndMutate()
                                                       throws IOException

Throws:

IOException

testWithCheckAndMutate

@TestTemplate
public void testWithCheckAndMutate()
                            throws Exception

Throws:

Exception