public class TestAsyncClientPauseForServerOverloaded extends Object
| Modifier and Type | Class and Description | 
|---|---|
(package private) static class  | 
TestAsyncClientPauseForServerOverloaded.FailMode  | 
static class  | 
TestAsyncClientPauseForServerOverloaded.OverloadedQueue  | 
static class  | 
TestAsyncClientPauseForServerOverloaded.OverloadedRpcScheduler  | 
static class  | 
TestAsyncClientPauseForServerOverloaded.OverloadedRpcSchedulerFactory  | 
| Modifier and Type | Field and Description | 
|---|---|
static HBaseClassTestRule | 
CLASS_RULE  | 
private static org.apache.hadoop.hbase.client.AsyncConnection | 
CONN  | 
private static byte[] | 
FAMILY  | 
private static TestAsyncClientPauseForServerOverloaded.FailMode | 
MODE  | 
private static long | 
PAUSE_FOR_SERVER_OVERLOADED_MILLIS  | 
private static long | 
PAUSE_FOR_SERVER_OVERLOADED_NANOS  | 
private static byte[] | 
QUALIFIER  | 
private static org.apache.hadoop.hbase.TableName | 
TABLE_NAME  | 
private static HBaseTestingUtility | 
UTIL  | 
| Constructor and Description | 
|---|
TestAsyncClientPauseForServerOverloaded()  | 
| Modifier and Type | Method and Description | 
|---|---|
private void | 
assertTime(Callable<Void> callable,
          long time)  | 
static void | 
setUp()  | 
void | 
setUpBeforeTest()  | 
static void | 
tearDown()  | 
void | 
tearDownAfterTest()  | 
void | 
testBatch()  | 
void | 
testGet()  | 
void | 
testScan()  | 
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseTestingUtility UTIL
private static org.apache.hadoop.hbase.TableName TABLE_NAME
private static byte[] FAMILY
private static byte[] QUALIFIER
private static long PAUSE_FOR_SERVER_OVERLOADED_NANOS
private static long PAUSE_FOR_SERVER_OVERLOADED_MILLIS
private static org.apache.hadoop.hbase.client.AsyncConnection CONN
private static volatile TestAsyncClientPauseForServerOverloaded.FailMode MODE
public TestAsyncClientPauseForServerOverloaded()
public void setUpBeforeTest() throws IOException
IOExceptionpublic void tearDownAfterTest() throws IOException
IOExceptionprivate void assertTime(Callable<Void> callable, long time) throws Exception
ExceptionCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.