Package org.apache.hadoop.hbase.client

Class TestAsyncTableRpcPriority

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncTableRpcPriority

@Tag("org.apache.hadoop.hbase.testclassification.ClientTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
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
private static org.apache.hadoop.conf.Configuration	CONF
private org.apache.hadoop.hbase.client.AsyncConnection	conn
String	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(org.junit.jupiter.api.TestInfo testInfo)
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

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 String name

Constructor Details

TestAsyncTableRpcPriority

public TestAsyncTableRpcPriority()

Method Details

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           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

@Test
public void testGet()

testGetNormalTable

@Test
public void testGetNormalTable()

testGetSystemTable

@Test
public void testGetSystemTable()

testGetMetaTable

@Test
public void testGetMetaTable()

testPut

@Test
public void testPut()

testPutNormalTable

@Test
public void testPutNormalTable()

testPutSystemTable

@Test
public void testPutSystemTable()

testPutMetaTable

@Test
public void testPutMetaTable()

testDelete

@Test
public void testDelete()

testDeleteNormalTable

@Test
public void testDeleteNormalTable()

testDeleteSystemTable

@Test
public void testDeleteSystemTable()

testDeleteMetaTable

@Test
public void testDeleteMetaTable()

testAppend

@Test
public void testAppend()

testAppendNormalTable

@Test
public void testAppendNormalTable()

testAppendSystemTable

@Test
public void testAppendSystemTable()

testAppendMetaTable

@Test
public void testAppendMetaTable()

testIncrement

@Test
public void testIncrement()

testIncrementNormalTable

@Test
public void testIncrementNormalTable()

testIncrementSystemTable

@Test
public void testIncrementSystemTable()

testIncrementMetaTable

@Test
public void testIncrementMetaTable()

testCheckAndPut

@Test
public void testCheckAndPut()

testCheckAndPutNormalTable

@Test
public void testCheckAndPutNormalTable()

testCheckAndPutSystemTable

@Test
public void testCheckAndPutSystemTable()

testCheckAndPutMetaTable

@Test
public void testCheckAndPutMetaTable()

testCheckAndDelete

@Test
public void testCheckAndDelete()

testCheckAndDeleteNormalTable

@Test
public void testCheckAndDeleteNormalTable()

testCheckAndDeleteSystemTable

@Test
public void testCheckAndDeleteSystemTable()

testCheckAndDeleteMetaTable

@Test
public void testCheckAndDeleteMetaTable()

testCheckAndMutate

@Test
public void testCheckAndMutate()
                        throws IOException

Throws:

IOException

testCheckAndMutateNormalTable

@Test
public void testCheckAndMutateNormalTable()
                                   throws IOException

Throws:

IOException

testCheckAndMutateSystemTable

@Test
public void testCheckAndMutateSystemTable()
                                   throws IOException

Throws:

IOException

testCheckAndMutateMetaTable

@Test
public void testCheckAndMutateMetaTable()
                                 throws IOException

Throws:

IOException

mockScanReturnRenewFuture

private CompletableFuture<Void> mockScanReturnRenewFuture(int scanPriority)

testScan

@Test
public void testScan()
              throws Exception

Throws:

Exception

testScanNormalTable

@Test
public void testScanNormalTable()
                         throws Exception

Throws:

Exception

testScanSystemTable

@Test
public void testScanSystemTable()
                         throws Exception

Throws:

Exception

testScanMetaTable

@Test
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

@Test
public void testBatchNormalTable()

testBatchSystemTable

@Test
public void testBatchSystemTable()

testBatchMetaTable

@Test
public void testBatchMetaTable()