Package org.apache.hadoop.hbase.client

Class TestAsyncTableRpcPriority

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncTableRpcPriority

public class TestAsyncTableRpcPriority
extends Object

Confirm that we will set the priority in HBaseRpcController for several table operations.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	CONF
private org.apache.hadoop.hbase.client.AsyncConnection	conn
org.junit.rules.TestName	name
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface	stub
private ExecutorService	threadPool

Constructor Summary

Constructors

Constructor	Description
TestAsyncTableRpcPriority()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.ipc.HBaseRpcController	assertPriority(int priority)
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest	assertScannerCloseRequest()
private CompletableFuture<Void>	mockScanReturnRenewFuture(int scanPriority)
void	setUp()
void	testAppend()
void	testAppendMetaTable()
void	testAppendNormalTable()
void	testAppendSystemTable()
void	testBatchMetaTable()
void	testBatchNormalTable()
void	testBatchSystemTable()
void	testCheckAndDelete()
void	testCheckAndDeleteMetaTable()
void	testCheckAndDeleteNormalTable()
void	testCheckAndDeleteSystemTable()
void	testCheckAndMutate()
void	testCheckAndMutateMetaTable()
void	testCheckAndMutateNormalTable()
void	testCheckAndMutateSystemTable()
void	testCheckAndPut()
void	testCheckAndPutMetaTable()
void	testCheckAndPutNormalTable()
void	testCheckAndPutSystemTable()
void	testDelete()
void	testDeleteMetaTable()
void	testDeleteNormalTable()
void	testDeleteSystemTable()
private void	testForTable(org.apache.hadoop.hbase.TableName tableName, CompletableFuture<Void> renewFuture, Optional<Integer> priority)
void	testGet()
void	testGetMetaTable()
void	testGetNormalTable()
void	testGetSystemTable()
void	testIncrement()
void	testIncrementMetaTable()
void	testIncrementNormalTable()
void	testIncrementSystemTable()
void	testPut()
void	testPutMetaTable()
void	testPutNormalTable()
void	testPutSystemTable()
void	testScan()
void	testScanMetaTable()
void	testScanNormalTable()
void	testScanSystemTable()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

CONF

private static org.apache.hadoop.conf.Configuration CONF

stub

private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub

threadPool

private ExecutorService threadPool

conn

private org.apache.hadoop.hbase.client.AsyncConnection conn

name

public org.junit.rules.TestName name

Constructor Details

TestAsyncTableRpcPriority

public TestAsyncTableRpcPriority()

Method Details

setUp

public void setUp()
           throws IOException

Throws:

IOException

assertPriority

private org.apache.hadoop.hbase.ipc.HBaseRpcController assertPriority(int priority)

assertScannerCloseRequest

private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest assertScannerCloseRequest()

testGet

public void testGet()

testGetNormalTable

public void testGetNormalTable()

testGetSystemTable

public void testGetSystemTable()

testGetMetaTable

public void testGetMetaTable()

testPut

public void testPut()

testPutNormalTable

public void testPutNormalTable()

testPutSystemTable

public void testPutSystemTable()

testPutMetaTable

public void testPutMetaTable()

testDelete

public void testDelete()

testDeleteNormalTable

public void testDeleteNormalTable()

testDeleteSystemTable

public void testDeleteSystemTable()

testDeleteMetaTable

public void testDeleteMetaTable()

testAppend

public void testAppend()

testAppendNormalTable

public void testAppendNormalTable()

testAppendSystemTable

public void testAppendSystemTable()

testAppendMetaTable

public void testAppendMetaTable()

testIncrement

public void testIncrement()

testIncrementNormalTable

public void testIncrementNormalTable()

testIncrementSystemTable

public void testIncrementSystemTable()

testIncrementMetaTable

public void testIncrementMetaTable()

testCheckAndPut

public void testCheckAndPut()

testCheckAndPutNormalTable

public void testCheckAndPutNormalTable()

testCheckAndPutSystemTable

public void testCheckAndPutSystemTable()

testCheckAndPutMetaTable

public void testCheckAndPutMetaTable()

testCheckAndDelete

public void testCheckAndDelete()

testCheckAndDeleteNormalTable

public void testCheckAndDeleteNormalTable()

testCheckAndDeleteSystemTable

public void testCheckAndDeleteSystemTable()

testCheckAndDeleteMetaTable

public void testCheckAndDeleteMetaTable()

testCheckAndMutate

public void testCheckAndMutate()
                        throws IOException

Throws:

IOException

testCheckAndMutateNormalTable

public void testCheckAndMutateNormalTable()
                                   throws IOException

Throws:

IOException

testCheckAndMutateSystemTable

public void testCheckAndMutateSystemTable()
                                   throws IOException

Throws:

IOException

testCheckAndMutateMetaTable

public void testCheckAndMutateMetaTable()
                                 throws IOException

Throws:

IOException

mockScanReturnRenewFuture

private CompletableFuture<Void> mockScanReturnRenewFuture(int scanPriority)

testScan

public void testScan()
              throws Exception

Throws:

Exception

testScanNormalTable

public void testScanNormalTable()
                         throws Exception

Throws:

Exception

testScanSystemTable

public void testScanSystemTable()
                         throws Exception

Throws:

Exception

testScanMetaTable

public void testScanMetaTable()
                       throws Exception

Throws:

Exception

testForTable

private void testForTable(org.apache.hadoop.hbase.TableName tableName,
 CompletableFuture<Void> renewFuture,
 Optional<Integer> priority)
                   throws Exception

Throws:

Exception

testBatchNormalTable

public void testBatchNormalTable()

testBatchSystemTable

public void testBatchSystemTable()

testBatchMetaTable

public void testBatchMetaTable()