org.apache.hadoop.hbase.client

Class TestAsyncTableBatch

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncTableBatch

public class TestAsyncTableBatch
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestAsyncTableBatch.ErrorInjectObserver

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
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
Function<org.apache.hadoop.hbase.TableName,org.apache.hadoop.hbase.client.AsyncTable<?>>	tableGetter
String	tableType
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestAsyncTableBatch()

Method Summary

Modifier and Type	Method and 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 List<Object[]>	params()
static void	setUp()
void	setUpBeforeTest()
static void	tearDown()
void	tearDownAfterTest()
void	test()
void	testInvalidPut()
void	testInvalidPutInRowMutations()
void	testInvalidPutInRowMutationsInCheckAndMutate()
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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TEST_UTIL

private static final HBaseTestingUtility 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

tableType

public String tableType

tableGetter

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

Constructor Detail

TestAsyncTableBatch

public TestAsyncTableBatch()

Method Detail

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)

params

public static List<Object[]> params()

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

setUpBeforeTest

public void setUpBeforeTest()
                     throws IOException,
                            InterruptedException

Throws:

IOException

InterruptedException

tearDownAfterTest

public void tearDownAfterTest()
                       throws IOException

Throws:

IOException

getRow

private byte[] getRow(int i)

test

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

Throws:

InterruptedException

ExecutionException

IOException

TimeoutException

testWithRegionServerFailover

public void testWithRegionServerFailover()
                                  throws Exception

Throws:

Exception

testMixed

public void testMixed()
               throws InterruptedException,
                      ExecutionException,
                      IOException

Throws:

InterruptedException

ExecutionException

IOException

testPartialSuccess

public void testPartialSuccess()
                        throws IOException,
                               InterruptedException,
                               ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testPartialSuccessOnSameRegion

public void testPartialSuccessOnSameRegion()
                                    throws InterruptedException,
                                           ExecutionException

Throws:

InterruptedException

ExecutionException

testInvalidPut

public void testInvalidPut()

testInvalidPutInRowMutations

public void testInvalidPutInRowMutations()
                                  throws IOException

Throws:

IOException

testInvalidPutInRowMutationsInCheckAndMutate

public void testInvalidPutInRowMutationsInCheckAndMutate()
                                                  throws IOException

Throws:

IOException

testWithCheckAndMutate

public void testWithCheckAndMutate()
                            throws Exception

Throws:

Exception