Package org.apache.hadoop.hbase.client

Class TestConnection

java.lang.Object

org.apache.hadoop.hbase.client.TestConnection

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

This class is for testing Connection.

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	FAM_NAM
private static final org.slf4j.Logger	LOG
private String	methodName
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
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
static void	setUpBeforeClass()
void	tearDown(org.junit.jupiter.api.TestInfo testInfo)
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

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

methodName

private String methodName

Constructor Details

TestConnection

public TestConnection()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)

tearDown

@AfterEach
public void tearDown(org.junit.jupiter.api.TestInfo testInfo)
              throws IOException

Throws:

IOException

testAdminFactory

@Test
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

@Test
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

@Test
public void testConnectionNotAllowsInterrupt()
                                      throws Exception

Throws:

Exception

testConnectionClose

private void testConnectionClose(boolean allowsInterrupt)
                          throws Exception

Throws:

Exception

testConnectionIdle

@Test
public void testConnectionIdle()
                        throws Exception

Test that connection can become idle without breaking everything.

Throws:

Exception

testClosing

@Test
public void testClosing()
                 throws Exception

Throws:

Exception

testCreateConnection

@Test
public void testCreateConnection()
                          throws Exception

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

Throws:

Exception

testLocateRegionsWithRegionReplicas

@Test
public void testLocateRegionsWithRegionReplicas()
                                         throws IOException

Throws:

IOException

testClosedConnection

@Test
public void testClosedConnection()
                          throws Throwable

Throws:

Throwable

testCancelConnectionMemoryLeak

@Test
public void testCancelConnectionMemoryLeak()
                                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException