org.apache.hadoop.hbase.client

Class TestAsyncReplicationAdminApi

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncAdminBase

org.apache.hadoop.hbase.client.TestAsyncReplicationAdminApi

public class TestAsyncReplicationAdminApi
extends TestAsyncAdminBase

Class to test asynchronous replication admin operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestAsyncReplicationAdminApi.DummyReplicationEndpoint

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private String	ID_ONE
private String	ID_TWO
private String	KEY_ONE
private 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 and Description
TestAsyncReplicationAdminApi()

Method Summary

Modifier and Type	Method and Description
void	clearPeerAndQueues()
static void	setUpBeforeClass()
void	testAddRemovePeer()
void	testAppendPeerTableCFs()
void	testEnableDisablePeer()
void	testInvalidClusterKey()
void	testInvalidReplicationEndpoint()
void	testNamespacesAndTableCfsConfigConflict()
void	testPeerBandwidth()
void	testPeerConfig()
void	testRemovePeerTableCFs()
void	testSetPeerNamespaces()
void	testSetReplicationEndpoint()

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

createTableWithDefaultConf, createTableWithDefaultConf, createTableWithDefaultConf, params, setUp, tearDown, tearDownAfterClass

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

ID_ONE

private final String ID_ONE

See Also:

Constant Field Values

KEY_ONE

private final String KEY_ONE

See Also:

Constant Field Values

ID_TWO

private final String ID_TWO

See Also:

Constant Field Values

KEY_TWO

private final String KEY_TWO

See Also:

Constant Field Values

Constructor Detail

TestAsyncReplicationAdminApi

public TestAsyncReplicationAdminApi()

Method Detail

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

testInvalidReplicationEndpoint

public void testInvalidReplicationEndpoint()
                                    throws InterruptedException

Throws:

InterruptedException

testSetReplicationEndpoint

public void testSetReplicationEndpoint()
                                throws InterruptedException,
                                       ExecutionException

Throws:

InterruptedException

ExecutionException