Package org.apache.hadoop.hbase.client

Class TestTableRpcPriority

java.lang.Object

org.apache.hadoop.hbase.client.TestTableRpcPriority

public class TestTableRpcPriority
extends Object

Test that correct rpc priority is sent to server from blocking Table calls. Currently only implements checks for scans, but more could be added here.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.client.Connection	conn
org.junit.rules.TestName	name
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface	stub

Constructor Summary

Constructors

Constructor	Description
TestTableRpcPriority()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.ipc.HBaseRpcController	assertControllerArgs(int priority)
private org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest	assertScannerCloseRequest()
private void	mockScan(int scanPriority)
void	setUp()
private void	testForTable(org.apache.hadoop.hbase.TableName tableName, Optional<Integer> priority)
void	testScan()
void	testScanMetaTable()
void	testScanNormalTable()
void	testScanSuperHighPriority()	This test verifies that our closeScanner request honors the original priority of the scan if it's greater than our expected HIGH_QOS for close calls.
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

name

public org.junit.rules.TestName name

stub

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

conn

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

Constructor Details

TestTableRpcPriority

public TestTableRpcPriority()

Method Details

setUp

public void setUp()
           throws IOException,
org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testScan

public void testScan()
              throws Exception

Throws:

Exception

testScanSuperHighPriority

public void testScanSuperHighPriority()
                               throws Exception

This test verifies that our closeScanner request honors the original priority of the scan if it's greater than our expected HIGH_QOS for close calls.

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,
 Optional<Integer> priority)
                   throws Exception

Throws:

Exception

mockScan

private void mockScan(int scanPriority)
               throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

assertControllerArgs

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

assertScannerCloseRequest

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