public class TestAsyncTableRpcPriority extends Object
HBaseRpcController
for several table operations.Modifier and Type | Field and Description |
---|---|
static 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 and Description |
---|
TestAsyncTableRpcPriority() |
public static final HBaseClassTestRule CLASS_RULE
private static org.apache.hadoop.conf.Configuration CONF
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub
private ExecutorService threadPool
private org.apache.hadoop.hbase.client.AsyncConnection conn
public org.junit.rules.TestName name
public TestAsyncTableRpcPriority()
public void setUp() throws IOException
IOException
private org.apache.hadoop.hbase.ipc.HBaseRpcController assertPriority(int priority)
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest assertScannerCloseRequest()
public void testGet()
public void testGetNormalTable()
public void testGetSystemTable()
public void testGetMetaTable()
public void testPut()
public void testPutNormalTable()
public void testPutSystemTable()
public void testPutMetaTable()
public void testDelete()
public void testDeleteNormalTable()
public void testDeleteSystemTable()
public void testDeleteMetaTable()
public void testAppend()
public void testAppendNormalTable()
public void testAppendSystemTable()
public void testAppendMetaTable()
public void testIncrement()
public void testIncrementNormalTable()
public void testIncrementSystemTable()
public void testIncrementMetaTable()
public void testCheckAndPut()
public void testCheckAndPutNormalTable()
public void testCheckAndPutSystemTable()
public void testCheckAndPutMetaTable()
public void testCheckAndDelete()
public void testCheckAndDeleteNormalTable()
public void testCheckAndDeleteSystemTable()
public void testCheckAndDeleteMetaTable()
public void testCheckAndMutate() throws IOException
IOException
public void testCheckAndMutateNormalTable() throws IOException
IOException
public void testCheckAndMutateSystemTable() throws IOException
IOException
public void testCheckAndMutateMetaTable() throws IOException
IOException
private CompletableFuture<Void> mockScanReturnRenewFuture(int scanPriority)
public void testScanNormalTable() throws Exception
Exception
public void testScanSystemTable() throws Exception
Exception
public void testScanMetaTable() throws Exception
Exception
private void testForTable(org.apache.hadoop.hbase.TableName tableName, CompletableFuture<Void> renewFuture, Optional<Integer> priority) throws Exception
Exception
public void testBatchNormalTable()
public void testBatchSystemTable()
public void testBatchMetaTable()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.