Package org.apache.hadoop.hbase

Class TestCustomPriorityRpcControllerFactory

java.lang.Object

org.apache.hadoop.hbase.TestCustomPriorityRpcControllerFactory

@Tag("org.apache.hadoop.hbase.testclassification.ClientTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestCustomPriorityRpcControllerFactory
extends Object

Tests that one can implement their own RpcControllerFactory and expect it to successfully pass custom priority values to the server for all HTable calls.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestCustomPriorityRpcControllerFactory.PriorityController
static class	TestCustomPriorityRpcControllerFactory.PriorityRegionServer
static class	TestCustomPriorityRpcControllerFactory.PriorityRpcControllerFactory
static class	TestCustomPriorityRpcControllerFactory.PriorityRpcServices
private static enum	TestCustomPriorityRpcControllerFactory.State
private static interface	TestCustomPriorityRpcControllerFactory.ThrowingCallable

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Connection	CONN
private static final AtomicInteger	EXPECTED_PRIORITY
private static final byte[]	FAMILY
private static final int	MIN_CUSTOM_PRIORITY
private static final byte[]	QUALIFIER
private static final byte[]	ROW
private static final AtomicReference<TestCustomPriorityRpcControllerFactory.State>	STATE
private static org.apache.hadoop.hbase.client.Table	TABLE
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	UTIL
private static final byte[]	VALUE

Constructor Summary

Constructors

Constructor	Description
TestCustomPriorityRpcControllerFactory()

Method Summary

Modifier and Type	Method	Description
static void	setUpClass()
void	testAppendPriority()
void	testCheckAndMutatePriority()
void	testDeletePriority()
void	testExistsPriority()
private void	testForCall(TestCustomPriorityRpcControllerFactory.ThrowingCallable callable)
void	testIncrementPriority()
void	testMultiGetsPriority()
void	testMultiPutsPriority()
void	testMutatePriority()
void	testPutPriority()
void	testScanPriority()
void	tetGetPriority()

Methods inherited from class java.lang.Object

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

Field Details

UTIL

private static final HBaseTestingUtil UTIL

STATE

private static final AtomicReference<TestCustomPriorityRpcControllerFactory.State> STATE

EXPECTED_PRIORITY

private static final AtomicInteger EXPECTED_PRIORITY

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

private static final byte[] FAMILY

ROW

private static final byte[] ROW

QUALIFIER

private static final byte[] QUALIFIER

VALUE

private static final byte[] VALUE

MIN_CUSTOM_PRIORITY

private static final int MIN_CUSTOM_PRIORITY

See Also:

• Constant Field Values

CONN

private static org.apache.hadoop.hbase.client.Connection CONN

TABLE

private static org.apache.hadoop.hbase.client.Table TABLE

Constructor Details

TestCustomPriorityRpcControllerFactory

public TestCustomPriorityRpcControllerFactory()

Method Details

setUpClass

@BeforeAll
public static void setUpClass()
                       throws Exception

Throws:

Exception

tetGetPriority

@Test
public void tetGetPriority()
                    throws Exception

Throws:

Exception

testDeletePriority

@Test
public void testDeletePriority()
                        throws Exception

Throws:

Exception

testIncrementPriority

@Test
public void testIncrementPriority()
                           throws Exception

Throws:

Exception

testAppendPriority

@Test
public void testAppendPriority()
                        throws Exception

Throws:

Exception

testPutPriority

@Test
public void testPutPriority()
                     throws Exception

Throws:

Exception

testExistsPriority

@Test
public void testExistsPriority()
                        throws Exception

Throws:

Exception

testMutatePriority

@Test
public void testMutatePriority()
                        throws Exception

Throws:

Exception

testCheckAndMutatePriority

@Test
public void testCheckAndMutatePriority()
                                throws Exception

Throws:

Exception

testMultiGetsPriority

@Test
public void testMultiGetsPriority()
                           throws Exception

Throws:

Exception

testMultiPutsPriority

@Test
public void testMultiPutsPriority()
                           throws Exception

Throws:

Exception

testScanPriority

@Test
public void testScanPriority()
                      throws Exception

Throws:

Exception

testForCall

private void testForCall(TestCustomPriorityRpcControllerFactory.ThrowingCallable callable)
                  throws Exception

Throws:

Exception