Package org.apache.hadoop.hbase.client

Class TestConnection

java.lang.Object

org.apache.hadoop.hbase.client.TestConnection

public class TestConnection
extends Object

This class is for testing Connection.

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 int	RPC_RETRY
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestConnection()

Method Summary

Modifier and Type	Method	Description
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testAdminFactory()	Naive test to check that Connection#getAdmin returns a properly constructed HBaseAdmin object
void	testCancelConnectionMemoryLeak()
void	testClosedConnection()
void	testClosing()
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	testConnectionIdle()	Test that connection can become idle without breaking everything.
void	testConnectionNotAllowsInterrupt()
void	testCreateConnection()	Trivial test to verify that nobody messes with ConnectionFactory.createConnection(Configuration)
void	testLocateRegionsWithRegionReplicas()

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 HBaseTestingUtil TEST_UTIL

FAM_NAM

private static final byte[] FAM_NAM

ROW

private static final byte[] ROW

RPC_RETRY

private static final int RPC_RETRY

See Also:

• Constant Field Values

name

public org.junit.rules.TestName name

Constructor Details

TestConnection

public TestConnection()

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

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

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

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

testLocateRegionsWithRegionReplicas

public void testLocateRegionsWithRegionReplicas()
                                         throws IOException

Throws:

IOException

testClosedConnection

public void testClosedConnection()
                          throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
Throwable

Throws:

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

Throwable

testCancelConnectionMemoryLeak

public void testCancelConnectionMemoryLeak()
                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException