Package org.apache.hadoop.hbase.client

Class TestAsyncTable

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncTable

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

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.AsyncConnection	ASYNC_CONN
private static byte[]	FAMILY
private final Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>>	getTable
private static int	MAX_KEY_VALUE_SIZE
private static byte[]	QUALIFIER
private byte[]	row
private static final AtomicInteger	ROW_COUNTER
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	TEST_UTIL
private static byte[]	VALUE

Constructor Summary

Constructors

Constructor	Description
TestAsyncTable(Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>> getTable)

Method Summary

Modifier and Type	Method	Description
private byte[]	concat(byte[] base, int index)
private static org.apache.hadoop.hbase.client.AsyncTable<?>	getRawTable()
private static org.apache.hadoop.hbase.client.AsyncTable<?>	getTable()
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testAppend()
void	testCheckAndAppend()
void	testCheckAndAppendBatch()
void	testCheckAndDelete()
void	testCheckAndDeleteForOldApi()	Deprecated.
void	testCheckAndIncrement()
void	testCheckAndIncrementBatch()
void	testCheckAndMutate()
void	testCheckAndMutateBatch()
void	testCheckAndMutateBatch2()
void	testCheckAndMutateBatchWithFilter()
void	testCheckAndMutateBatchWithFilterAndTimeRange()
void	testCheckAndMutateForOldApi()	Deprecated.
void	testCheckAndMutateWithFilterAndTimeRange()
void	testCheckAndMutateWithFilterAndTimeRangeForOldApi()	Deprecated.
void	testCheckAndMutateWithMultipleFilters()
void	testCheckAndMutateWithMultipleFiltersForOldApi()	Deprecated.
void	testCheckAndMutateWithoutConditionForOldApi()	Deprecated.
void	testCheckAndMutateWithSingleFilter()
void	testCheckAndMutateWithSingleFilterForOldApi()	Deprecated.
void	testCheckAndMutateWithTimeRange()
void	testCheckAndMutateWithTimeRangeForOldApi()	Deprecated.
void	testCheckAndMutateWithTimestampFilter()
void	testCheckAndMutateWithTimestampFilterForOldApi()	Deprecated.
void	testCheckAndPut()
void	testCheckAndPutForOldApi()	Deprecated.
void	testCheckAndRowMutations()
void	testCheckAndRowMutationsBatch()
void	testDisabled()
void	testIncrement()
void	testInvalidMutation()
void	testInvalidMutationInRowMutations()
void	testInvalidMutationInRowMutationsInCheckAndMutate()
void	testMutateRow()
void	testSimple()
void	testSimpleMultiple()

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

QUALIFIER

private static byte[] QUALIFIER

VALUE

private static byte[] VALUE

MAX_KEY_VALUE_SIZE

private static int MAX_KEY_VALUE_SIZE

ASYNC_CONN

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

ROW_COUNTER

private static final AtomicInteger ROW_COUNTER

row

private byte[] row

getTable

private final Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>> getTable

Constructor Details

TestAsyncTable

public TestAsyncTable(Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>> getTable)

Method Details

getRawTable

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

getTable

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

parameters

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

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()
           throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testSimple

@TestTemplate
public void testSimple()
                throws Exception

Throws:

Exception

concat

private byte[] concat(byte[] base,
 int index)

testSimpleMultiple

@TestTemplate
public void testSimpleMultiple()
                        throws Exception

Throws:

Exception

testIncrement

@TestTemplate
public void testIncrement()
                   throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testAppend

@TestTemplate
public void testAppend()
                throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testMutateRow

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

Throws:

InterruptedException

ExecutionException

IOException

testCheckAndPutForOldApi

@TestTemplate
@Deprecated
public void testCheckAndPutForOldApi()
                              throws InterruptedException,
ExecutionException

Deprecated.

Throws:

InterruptedException

ExecutionException

testCheckAndDeleteForOldApi

@TestTemplate
@Deprecated
public void testCheckAndDeleteForOldApi()
                                 throws InterruptedException,
ExecutionException

Deprecated.

Throws:

InterruptedException

ExecutionException

testCheckAndMutateForOldApi

@TestTemplate
@Deprecated
public void testCheckAndMutateForOldApi()
                                 throws InterruptedException,
ExecutionException

Deprecated.

Throws:

InterruptedException

ExecutionException

testCheckAndMutateWithTimeRangeForOldApi

@TestTemplate
@Deprecated
public void testCheckAndMutateWithTimeRangeForOldApi()
                                              throws Exception

Deprecated.

Throws:

Exception

testCheckAndMutateWithSingleFilterForOldApi

@TestTemplate
@Deprecated
public void testCheckAndMutateWithSingleFilterForOldApi()
                                                 throws Throwable

Deprecated.

Throws:

Throwable

testCheckAndMutateWithMultipleFiltersForOldApi

@TestTemplate
@Deprecated
public void testCheckAndMutateWithMultipleFiltersForOldApi()
                                                    throws Throwable

Deprecated.

Throws:

Throwable

testCheckAndMutateWithTimestampFilterForOldApi

@TestTemplate
@Deprecated
public void testCheckAndMutateWithTimestampFilterForOldApi()
                                                    throws Throwable

Deprecated.

Throws:

Throwable

testCheckAndMutateWithFilterAndTimeRangeForOldApi

@TestTemplate
@Deprecated
public void testCheckAndMutateWithFilterAndTimeRangeForOldApi()
                                                       throws Throwable

Deprecated.

Throws:

Throwable

testCheckAndMutateWithoutConditionForOldApi

@TestTemplate
@Deprecated
public void testCheckAndMutateWithoutConditionForOldApi()

Deprecated.

testCheckAndPut

@TestTemplate
public void testCheckAndPut()
                     throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testCheckAndDelete

@TestTemplate
public void testCheckAndDelete()
                        throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testCheckAndMutate

@TestTemplate
public void testCheckAndMutate()
                        throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testCheckAndMutateWithTimeRange

@TestTemplate
public void testCheckAndMutateWithTimeRange()
                                     throws Exception

Throws:

Exception

testCheckAndMutateWithSingleFilter

@TestTemplate
public void testCheckAndMutateWithSingleFilter()
                                        throws Throwable

Throws:

Throwable

testCheckAndMutateWithMultipleFilters

@TestTemplate
public void testCheckAndMutateWithMultipleFilters()
                                           throws Throwable

Throws:

Throwable

testCheckAndMutateWithTimestampFilter

@TestTemplate
public void testCheckAndMutateWithTimestampFilter()
                                           throws Throwable

Throws:

Throwable

testCheckAndMutateWithFilterAndTimeRange

@TestTemplate
public void testCheckAndMutateWithFilterAndTimeRange()
                                              throws Throwable

Throws:

Throwable

testCheckAndIncrement

@TestTemplate
public void testCheckAndIncrement()
                           throws Throwable

Throws:

Throwable

testCheckAndAppend

@TestTemplate
public void testCheckAndAppend()
                        throws Throwable

Throws:

Throwable

testCheckAndRowMutations

@TestTemplate
public void testCheckAndRowMutations()
                              throws Throwable

Throws:

Throwable

testCheckAndMutateBatch

@TestTemplate
public void testCheckAndMutateBatch()
                             throws Throwable

Throws:

Throwable

testCheckAndMutateBatch2

@TestTemplate
public void testCheckAndMutateBatch2()
                              throws Throwable

Throws:

Throwable

testCheckAndMutateBatchWithFilter

@TestTemplate
public void testCheckAndMutateBatchWithFilter()
                                       throws Throwable

Throws:

Throwable

testCheckAndMutateBatchWithFilterAndTimeRange

@TestTemplate
public void testCheckAndMutateBatchWithFilterAndTimeRange()
                                                   throws Throwable

Throws:

Throwable

testCheckAndIncrementBatch

@TestTemplate
public void testCheckAndIncrementBatch()
                                throws Throwable

Throws:

Throwable

testCheckAndAppendBatch

@TestTemplate
public void testCheckAndAppendBatch()
                             throws Throwable

Throws:

Throwable

testCheckAndRowMutationsBatch

@TestTemplate
public void testCheckAndRowMutationsBatch()
                                   throws Throwable

Throws:

Throwable

testDisabled

@TestTemplate
public void testDisabled()
                  throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testInvalidMutation

@TestTemplate
public void testInvalidMutation()
                         throws Exception

Throws:

Exception

testInvalidMutationInRowMutations

@TestTemplate
public void testInvalidMutationInRowMutations()
                                       throws IOException

Throws:

IOException

testInvalidMutationInRowMutationsInCheckAndMutate

@TestTemplate
public void testInvalidMutationInRowMutationsInCheckAndMutate()
                                                       throws IOException

Throws:

IOException