public class TestAsyncTable extends Object
Modifier and Type | Field and Description |
---|---|
private static org.apache.hadoop.hbase.client.AsyncConnection |
ASYNC_CONN |
static HBaseClassTestRule |
CLASS_RULE |
private static byte[] |
FAMILY |
Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>> |
getTable |
private static int |
MAX_KEY_VALUE_SIZE |
private static byte[] |
QUALIFIER |
private byte[] |
row |
private static org.apache.hadoop.hbase.TableName |
TABLE_NAME |
private static HBaseTestingUtility |
TEST_UTIL |
org.junit.rules.TestName |
testName |
private static byte[] |
VALUE |
Constructor and Description |
---|
TestAsyncTable() |
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseTestingUtility TEST_UTIL
private static org.apache.hadoop.hbase.TableName TABLE_NAME
private static byte[] FAMILY
private static byte[] QUALIFIER
private static byte[] VALUE
private static int MAX_KEY_VALUE_SIZE
private static org.apache.hadoop.hbase.client.AsyncConnection ASYNC_CONN
public org.junit.rules.TestName testName
private byte[] row
public TestAsyncTable()
private static org.apache.hadoop.hbase.client.AsyncTable<?> getRawTable()
private static org.apache.hadoop.hbase.client.AsyncTable<?> getTable()
public static void setUpBeforeClass() throws Exception
Exception
public static void tearDownAfterClass() throws Exception
Exception
public void setUp() throws IOException, InterruptedException, ExecutionException
public void testSimple() throws Exception
Exception
private byte[] concat(byte[] base, int index)
public void testSimpleMultiple() throws Exception
Exception
public void testIncrement() throws InterruptedException, ExecutionException
public void testAppend() throws InterruptedException, ExecutionException
public void testMutateRow() throws InterruptedException, ExecutionException, IOException
@Deprecated public void testCheckAndPutForOldApi() throws InterruptedException, ExecutionException
@Deprecated public void testCheckAndDeleteForOldApi() throws InterruptedException, ExecutionException
@Deprecated public void testCheckAndMutateForOldApi() throws InterruptedException, ExecutionException
@Deprecated public void testCheckAndMutateWithTimeRangeForOldApi() throws Exception
Exception
@Deprecated public void testCheckAndMutateWithSingleFilterForOldApi() throws Throwable
Throwable
@Deprecated public void testCheckAndMutateWithMultipleFiltersForOldApi() throws Throwable
Throwable
@Deprecated public void testCheckAndMutateWithTimestampFilterForOldApi() throws Throwable
Throwable
@Deprecated public void testCheckAndMutateWithFilterAndTimeRangeForOldApi() throws Throwable
Throwable
@Deprecated public void testCheckAndMutateWithoutConditionForOldApi()
public void testCheckAndPut() throws InterruptedException, ExecutionException
public void testCheckAndDelete() throws InterruptedException, ExecutionException
public void testCheckAndMutate() throws InterruptedException, ExecutionException
public void testCheckAndMutateWithTimeRange() throws Exception
Exception
public void testCheckAndMutateWithSingleFilter() throws Throwable
Throwable
public void testCheckAndMutateWithMultipleFilters() throws Throwable
Throwable
public void testCheckAndMutateWithTimestampFilter() throws Throwable
Throwable
public void testCheckAndMutateWithFilterAndTimeRange() throws Throwable
Throwable
public void testCheckAndIncrement() throws Throwable
Throwable
public void testCheckAndAppend() throws Throwable
Throwable
public void testCheckAndRowMutations() throws Throwable
Throwable
public void testCheckAndMutateBatch() throws Throwable
Throwable
public void testCheckAndMutateBatch2() throws Throwable
Throwable
public void testCheckAndMutateBatchWithFilter() throws Throwable
Throwable
public void testCheckAndMutateBatchWithFilterAndTimeRange() throws Throwable
Throwable
public void testCheckAndIncrementBatch() throws Throwable
Throwable
public void testCheckAndAppendBatch() throws Throwable
Throwable
public void testCheckAndRowMutationsBatch() throws Throwable
Throwable
public void testDisabled() throws InterruptedException, ExecutionException
public void testInvalidPut()
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.