Package org.apache.hadoop.hbase.client

Class TestAsyncReplicationAdminApi

java.lang.Object

org.apache.hadoop.hbase.client.AbstractTestUpdateConfiguration

org.apache.hadoop.hbase.client.TestAsyncAdminBase

org.apache.hadoop.hbase.client.TestAsyncReplicationAdminApi

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

Class to test asynchronous replication admin operations.

Field Summary

Fields

Modifier and Type	Field	Description
private final String	ID_ONE
private final String	ID_TWO
private static String	KEY_ONE
private static String	KEY_TWO

Fields inherited from class org.apache.hadoop.hbase.client.TestAsyncAdminBase

admin, ASYNC_CONN, FAMILY, FAMILY_0, FAMILY_1, getAdmin, LOG, tableName, TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestAsyncReplicationAdminApi(Supplier<org.apache.hadoop.hbase.client.AsyncAdmin> admin)

Method Summary

Modifier and Type	Method	Description
void	clearPeerAndQueues()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testAddRemovePeer()
void	testAppendPeerTableCFs()
void	testClusterKeyWithTrailingSpace()
void	testEnableDisablePeer()
void	testInvalidClusterKey()
void	testInvalidReplicationEndpoint()
void	testNamespacesAndTableCfsConfigConflict()
void	testPeerBandwidth()
void	testPeerConfig()
void	testRemovePeerTableCFs()
void	testReplicationPeerModificationSwitch()
void	testReplicationPeerNotFoundException()	Tests that admin api throws ReplicationPeerNotFoundException if peer doesn't exist.
void	testSetPeerNamespaces()
void	testSetReplicationEndpoint()

Methods inherited from class org.apache.hadoop.hbase.client.TestAsyncAdminBase

createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, parameters, setUp, tearDown

Methods inherited from class org.apache.hadoop.hbase.client.AbstractTestUpdateConfiguration

addResourceToRegionServerConfiguration, replaceHBaseSiteXML, restoreHBaseSiteXML, setUpConfigurationFiles

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ID_ONE

private final String ID_ONE

See Also:

• Constant Field Values

KEY_ONE

private static String KEY_ONE

ID_TWO

private final String ID_TWO

See Also:

• Constant Field Values

KEY_TWO

private static String KEY_TWO

Constructor Details

TestAsyncReplicationAdminApi

public TestAsyncReplicationAdminApi(Supplier<org.apache.hadoop.hbase.client.AsyncAdmin> admin)

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

clearPeerAndQueues

@AfterEach
public void clearPeerAndQueues()
                        throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testAddRemovePeer

@TestTemplate
public void testAddRemovePeer()
                       throws Exception

Throws:

Exception

testPeerConfig

@TestTemplate
public void testPeerConfig()
                    throws Exception

Throws:

Exception

testEnableDisablePeer

@TestTemplate
public void testEnableDisablePeer()
                           throws Exception

Throws:

Exception

testAppendPeerTableCFs

@TestTemplate
public void testAppendPeerTableCFs()
                            throws Exception

Throws:

Exception

testRemovePeerTableCFs

@TestTemplate
public void testRemovePeerTableCFs()
                            throws Exception

Throws:

Exception

testSetPeerNamespaces

@TestTemplate
public void testSetPeerNamespaces()
                           throws Exception

Throws:

Exception

testNamespacesAndTableCfsConfigConflict

@TestTemplate
public void testNamespacesAndTableCfsConfigConflict()
                                             throws Exception

Throws:

Exception

testPeerBandwidth

@TestTemplate
public void testPeerBandwidth()
                       throws Exception

Throws:

Exception

testInvalidClusterKey

@TestTemplate
public void testInvalidClusterKey()
                           throws InterruptedException

Throws:

InterruptedException

testClusterKeyWithTrailingSpace

@TestTemplate
public void testClusterKeyWithTrailingSpace()
                                     throws Exception

Throws:

Exception

testInvalidReplicationEndpoint

@TestTemplate
public void testInvalidReplicationEndpoint()
                                    throws InterruptedException

Throws:

InterruptedException

testSetReplicationEndpoint

@TestTemplate
public void testSetReplicationEndpoint()
                                throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testReplicationPeerNotFoundException

@TestTemplate
public void testReplicationPeerNotFoundException()
                                          throws InterruptedException

Tests that admin api throws ReplicationPeerNotFoundException if peer doesn't exist.

Throws:

InterruptedException

testReplicationPeerModificationSwitch

@TestTemplate
public void testReplicationPeerModificationSwitch()
                                           throws Exception

Throws:

Exception