Package org.apache.hadoop.hbase.client

Class TestConnectionImplementation

java.lang.Object

org.apache.hadoop.hbase.client.TestConnectionImplementation

public class TestConnectionImplementation
extends Object

This class is for testing HBaseConnectionManager features

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestConnectionImplementation.BlockingFilter
private static class	TestConnectionImplementation.ThrowingCallerFactory

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	FAM_NAM
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static final byte[]	ROW
private static final byte[]	ROW_X
private static final int	RPC_RETRY
protected static final AtomicBoolean	syncBlockingFilter
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME1
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME2
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME3
private static final HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestConnectionImplementation()

Method Summary

Modifier and Type	Method	Description
private static void	assertEqualsWithJitter(long expected, long actual)
private static void	assertEqualsWithJitter(long expected, long actual, long jitterBase)
private int	setNumTries(org.apache.hadoop.hbase.client.ConnectionImplementation hci, int newVal)
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testAdminFactory()	Naive test to check that Connection#getAdmin returns a properly constructed HBaseAdmin object
void	testCacheSeqNums()	Test that stale cache updates don't override newer cached values.
void	testCancelConnectionMemoryLeak()
void	testClosing()
void	testClusterConnection()
void	testClusterStatus()
void	testConnection()	This test checks that one can connect to the cluster with only the ZooKeeper quorum set.
private void	testConnectionClose(boolean allowsInterrupt)
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	testCreateConnection()	Trivial test to verify that nobody messes with ConnectionFactory.createConnection(Configuration)
void	testErrorBackoffTimeCalculation()
private void	testLocateRegionsRetrySpecialPause(Class<? extends org.apache.hadoop.hbase.HBaseServerException> exceptionClass)
void	testLocateRegionsRetrySpecialPauseCDE()
void	testLocateRegionsRetrySpecialPauseCQTBE()
void	testLocateRegionsWithRegionReplicas()
void	testMetaLookupThreadPoolCreated()
void	testMulti()
void	testRegionCaching()	Test that when we delete a location using the first row of a region that we really delete it.

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

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

TABLE_NAME

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

TABLE_NAME1

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

TABLE_NAME2

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

TABLE_NAME3

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

FAM_NAM

private static final byte[] FAM_NAM

ROW

private static final byte[] ROW

ROW_X

private static final byte[] ROW_X

RPC_RETRY

private static final int RPC_RETRY

See Also:

• Constant Field Values

name

public org.junit.rules.TestName name

syncBlockingFilter

protected static final AtomicBoolean syncBlockingFilter

Constructor Details

TestConnectionImplementation

public TestConnectionImplementation()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws IOException

Throws:

IOException

testClusterConnection

public void testClusterConnection()
                           throws IOException

Throws:

IOException

testAdminFactory

public void testAdminFactory()
                      throws IOException

Naive test to check that Connection#getAdmin returns a properly constructed HBaseAdmin object

Throws:

IOException - Unable to construct admin

testClusterStatus

public void testClusterStatus()
                       throws Exception

Throws:

Exception

testConnectionCloseAllowsInterrupt

public void testConnectionCloseAllowsInterrupt()
                                        throws Exception

Test that we can handle connection close: it will trigger a retry, but the calls will finish.

Throws:

Exception

testConnectionNotAllowsInterrupt

public void testConnectionNotAllowsInterrupt()
                                      throws Exception

Throws:

Exception

testConnectionClose

private void testConnectionClose(boolean allowsInterrupt)
                          throws Exception

Throws:

Exception

testConnectionIdle

public void testConnectionIdle()
                        throws Exception

Test that connection can become idle without breaking everything.

Throws:

Exception

testConnectionCut

public void testConnectionCut()
                       throws Exception

Test that the connection to the dead server is cut immediately when we receive the notification.

Throws:

Exception

testRegionCaching

public void testRegionCaching()
                       throws Exception

Test that when we delete a location using the first row of a region that we really delete it.

Throws:

Exception

testConnectionManagement

public void testConnectionManagement()
                              throws Exception

Test that Connection or Pool are not closed when managed externally

Throws:

Exception

testCacheSeqNums

public void testCacheSeqNums()
                      throws Exception

Test that stale cache updates don't override newer cached values.

Throws:

Exception

testClosing

public void testClosing()
                 throws Exception

Throws:

Exception

testCreateConnection

public void testCreateConnection()
                          throws Exception

Trivial test to verify that nobody messes with ConnectionFactory.createConnection(Configuration)

Throws:

Exception

testConnection

public void testConnection()
                    throws Exception

This test checks that one can connect to the cluster with only the ZooKeeper quorum set. Other stuff like master address will be read from ZK by the client.

Throws:

Exception

setNumTries

private int setNumTries(org.apache.hadoop.hbase.client.ConnectionImplementation hci,
 int newVal)
                 throws Exception

Throws:

Exception

testMulti

public void testMulti()
               throws Exception

Throws:

Exception

testErrorBackoffTimeCalculation

public void testErrorBackoffTimeCalculation()
                                     throws Exception

Throws:

Exception

assertEqualsWithJitter

private static void assertEqualsWithJitter(long expected,
 long actual)

assertEqualsWithJitter

private static void assertEqualsWithJitter(long expected,
 long actual,
 long jitterBase)

testConnectionRideOverClusterRestart

public void testConnectionRideOverClusterRestart()
                                          throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testLocateRegionsWithRegionReplicas

public void testLocateRegionsWithRegionReplicas()
                                         throws IOException

Throws:

IOException

testLocateRegionsRetrySpecialPauseCQTBE

public void testLocateRegionsRetrySpecialPauseCQTBE()
                                             throws IOException

Throws:

IOException

testLocateRegionsRetrySpecialPauseCDE

public void testLocateRegionsRetrySpecialPauseCDE()
                                           throws IOException

Throws:

IOException

testLocateRegionsRetrySpecialPause

private void testLocateRegionsRetrySpecialPause(Class<? extends org.apache.hadoop.hbase.HBaseServerException> exceptionClass)
                                         throws IOException

Throws:

IOException

testMetaLookupThreadPoolCreated

public void testMetaLookupThreadPoolCreated()
                                     throws Exception

Throws:

Exception

testCancelConnectionMemoryLeak

public void testCancelConnectionMemoryLeak()
                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException