public class TestHCM
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
TestHCM.BlockingFilter |
static class |
TestHCM.SleepAndFailFirstTime
This copro sleeps 20 second.
|
static class |
TestHCM.SleepCoprocessor |
Modifier and Type | Field and Description |
---|---|
protected static java.util.concurrent.atomic.AtomicBoolean |
syncBlockingFilter |
Constructor and Description |
---|
TestHCM() |
Modifier and Type | Method and Description |
---|---|
void |
abortingHConnectionRemovesItselfFromHCM() |
static void |
setUpBeforeClass() |
static void |
tearDownAfterClass() |
void |
testAdminFactory()
Naive test to check that HConnection#getAdmin returns a properly constructed HBaseAdmin object
|
void |
testCacheSeqNums()
Test that stale cache updates don't override newer cached values.
|
void |
testClosing() |
void |
testClusterConnection() |
void |
testClusterStatus() |
void |
testConnection()
This test checks that one can connect to the cluster with only the
ZooKeeper quorum set.
|
void |
testConnectionCloseAllowsInterrupt()
Test that we can handle connection close: it will trigger a retry, but the calls will
finish.
|
void |
testConnectionCut()
Test that the connection to the dead server is cut immediately when we receive the
notification.
|
void |
testConnectionIdle()
Test that connection can become idle without breaking everything.
|
void |
testConnectionManagement()
Test that Connection or Pool are not closed when managed externally
|
void |
testConnectionNotAllowsInterrupt() |
void |
testConnectionRideOverClusterRestart() |
void |
testConnectionSameness()
Make sure that
Configuration instances that are essentially the
same map to the same HConnection instance. |
void |
testConnectionUniqueness()
Deprecated.
Tests deprecated functionality. Remove in 1.0.
|
void |
testCreateConnection()
Trivial test to verify that nobody messes with
HConnectionManager.createConnection(Configuration) |
void |
testDeleteForZKConnLeak()
Tests that a destroyed connection does not have a live zookeeper.
|
void |
testErrorBackoffTimeCalculation() |
void |
testMulti() |
void |
testOperationTimeout()
Test that an operation can fail if we read the global operation timeout, even if the
individual timeout is fine.
|
void |
testRegionCaching()
Test that when we delete a location using the first row of a region
that we really delete it.
|
void |
testRpcTimeout() |
protected static final java.util.concurrent.atomic.AtomicBoolean syncBlockingFilter
public static void setUpBeforeClass() throws java.lang.Exception
java.lang.Exception
public static void tearDownAfterClass() throws java.lang.Exception
java.lang.Exception
public void testClusterConnection() throws java.io.IOException
java.io.IOException
public void testAdminFactory() throws java.io.IOException
java.io.IOException
- Unable to construct adminpublic void testClusterStatus() throws java.lang.Exception
java.lang.Exception
public void testConnectionCloseAllowsInterrupt() throws java.lang.Exception
java.lang.Exception
public void testConnectionNotAllowsInterrupt() throws java.lang.Exception
java.lang.Exception
public void testOperationTimeout() throws java.lang.Exception
java.lang.Exception
public void testRpcTimeout() throws java.lang.Exception
java.lang.Exception
public void testConnectionIdle() throws java.lang.Exception
java.lang.Exception
public void testConnectionCut() throws java.lang.Exception
java.lang.Exception
public void abortingHConnectionRemovesItselfFromHCM() throws java.lang.Exception
java.lang.Exception
public void testRegionCaching() throws java.lang.Exception
java.lang.Exception
public void testConnectionManagement() throws java.lang.Exception
java.lang.Exception
public void testCacheSeqNums() throws java.lang.Exception
java.lang.Exception
public void testConnectionSameness() throws java.lang.Exception
Configuration
instances that are essentially the
same map to the same HConnection
instance.java.lang.Exception
@Deprecated public void testConnectionUniqueness() throws java.lang.Exception
ConnectionManager.HConnectionImplementation
in the HConnectionManager
class.java.lang.Exception
public void testClosing() throws java.lang.Exception
java.lang.Exception
public void testCreateConnection() throws java.lang.Exception
HConnectionManager.createConnection(Configuration)
java.lang.Exception
public void testConnection() throws java.lang.Exception
java.lang.Exception
public void testMulti() throws java.lang.Exception
java.lang.Exception
public void testErrorBackoffTimeCalculation() throws java.lang.Exception
java.lang.Exception
public void testDeleteForZKConnLeak() throws java.lang.Exception
java.lang.Exception
public void testConnectionRideOverClusterRestart() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException