org.apache.hadoop.hbase.client.replication

Class TestReplicationAdmin

java.lang.Object

org.apache.hadoop.hbase.client.replication.TestReplicationAdmin

public class TestReplicationAdmin
extends Object

Unit testing of ReplicationAdmin

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.hadoop.hbase.client.replication.ReplicationAdmin	admin
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.client.Admin	hbaseAdmin
private String	ID_ONE
private String	ID_SECOND
private String	KEY_ONE
private String	KEY_SECOND
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestReplicationAdmin()

Method Summary

Modifier and Type	Method and Description
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testAddInvalidPeer()
void	testAddPeerWithState()
void	testAddPeerWithUnDeletedQueues()
void	testAddRemovePeer() Simple testing of adding and removing peers, basically shows that all interactions with ZK work
void	testAppendPeerTableCFs()
void	testConcurrentPeerOperations()
void	testEnableDisable() basic checks that when we add a peer that it is enabled, and that we can disable
void	testNamespacesAndTableCfsConfigConflict()
void	testPeerBandwidth()
void	testPeerClusterKey()
void	testPeerConfig() Tests that the peer configuration used by ReplicationAdmin contains all the peer's properties.
void	testPeerConfigConflict()
void	testPeerExcludeNamespaces()
void	testPeerExcludeTableCFs()
void	testPeerReplicationEndpointImpl()
void	testRemovePeerTableCFs()
void	testSetPeerNamespaces()
void	testSetReplicateAllUserTables()

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

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

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_SECOND

private final String ID_SECOND

See Also:

Constant Field Values

KEY_SECOND

private final String KEY_SECOND

See Also:

Constant Field Values

admin

private static org.apache.hadoop.hbase.client.replication.ReplicationAdmin admin

hbaseAdmin

private static org.apache.hadoop.hbase.client.Admin hbaseAdmin

name

public org.junit.rules.TestName name

Constructor Detail

TestReplicationAdmin

public TestReplicationAdmin()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testConcurrentPeerOperations

public void testConcurrentPeerOperations()
                                  throws Exception

Throws:

Exception

testAddInvalidPeer

public void testAddInvalidPeer()

testAddRemovePeer

public void testAddRemovePeer()
                       throws Exception

Simple testing of adding and removing peers, basically shows that all interactions with ZK work

Throws:

Exception

testAddPeerWithState

public void testAddPeerWithState()
                          throws Exception

Throws:

Exception

testPeerConfig

public void testPeerConfig()
                    throws Exception

Tests that the peer configuration used by ReplicationAdmin contains all the peer's properties.

Throws:

Exception

testAddPeerWithUnDeletedQueues

public void testAddPeerWithUnDeletedQueues()
                                    throws Exception

Throws:

Exception

testEnableDisable

public void testEnableDisable()
                       throws Exception

basic checks that when we add a peer that it is enabled, and that we can disable

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

testSetReplicateAllUserTables

public void testSetReplicateAllUserTables()
                                   throws Exception

Throws:

Exception

testPeerExcludeNamespaces

public void testPeerExcludeNamespaces()
                               throws Exception

Throws:

Exception

testPeerExcludeTableCFs

public void testPeerExcludeTableCFs()
                             throws Exception

Throws:

Exception

testPeerConfigConflict

public void testPeerConfigConflict()
                            throws Exception

Throws:

Exception

testNamespacesAndTableCfsConfigConflict

public void testNamespacesAndTableCfsConfigConflict()
                                             throws Exception

Throws:

Exception

testPeerBandwidth

public void testPeerBandwidth()
                       throws Exception

Throws:

Exception

testPeerClusterKey

public void testPeerClusterKey()
                        throws Exception

Throws:

Exception

testPeerReplicationEndpointImpl

public void testPeerReplicationEndpointImpl()
                                     throws Exception

Throws:

Exception