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

public class TestAsyncReplicationAdminApi
extends TestAsyncAdminBase

Class to test asynchronous replication admin operations.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
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, testName

Constructor Summary

Constructors

Constructor	Description
TestAsyncReplicationAdminApi()

Method Summary

Modifier and Type	Method	Description
void	clearPeerAndQueues()
static void	setUpBeforeClass()
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, params, setUp, tearDown, tearDownAfterClass

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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

clearPeerAndQueues

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

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testAddRemovePeer

public void testAddRemovePeer()
                       throws Exception

Throws:

Exception

testPeerConfig

public void testPeerConfig()
                    throws Exception

Throws:

Exception

testEnableDisablePeer

public void testEnableDisablePeer()
                           throws Exception

Throws:

Exception

testAppendPeerTableCFs

public void testAppendPeerTableCFs()
                            throws Exception

Throws:

Exception

testRemovePeerTableCFs

public void testRemovePeerTableCFs()
                            throws Exception

Throws:

Exception

testSetPeerNamespaces

public void testSetPeerNamespaces()
                           throws Exception

Throws:

Exception

testNamespacesAndTableCfsConfigConflict

public void testNamespacesAndTableCfsConfigConflict()
                                             throws Exception

Throws:

Exception

testPeerBandwidth

public void testPeerBandwidth()
                       throws Exception

Throws:

Exception

testInvalidClusterKey

public void testInvalidClusterKey()
                           throws InterruptedException

Throws:

InterruptedException

testClusterKeyWithTrailingSpace

public void testClusterKeyWithTrailingSpace()
                                     throws Exception

Throws:

Exception

testInvalidReplicationEndpoint

public void testInvalidReplicationEndpoint()
                                    throws InterruptedException

Throws:

InterruptedException

testSetReplicationEndpoint

public void testSetReplicationEndpoint()
                                throws InterruptedException,
ExecutionException

Throws:

InterruptedException

ExecutionException

testReplicationPeerNotFoundException

public void testReplicationPeerNotFoundException()
                                          throws InterruptedException

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

Throws:

InterruptedException

testReplicationPeerModificationSwitch

public void testReplicationPeerModificationSwitch()
                                           throws Exception

Throws:

Exception