org.apache.hadoop.hbase.client.replication

Class TestReplicationAdminWithClusters

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.client.replication.TestReplicationAdminWithClusters

public class TestReplicationAdminWithClusters
extends TestReplicationBase

Unit testing of ReplicationAdmin with clusters

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestReplicationAdminWithClusters.TestUpdatableReplicationEndpoint

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static org.apache.hadoop.hbase.client.Admin	admin1
(package private) static org.apache.hadoop.hbase.client.Admin	admin2
(package private) static org.apache.hadoop.hbase.client.replication.ReplicationAdmin	adminExt
static HBaseClassTestRule	CLASS_RULE
(package private) static org.apache.hadoop.hbase.client.Connection	connection1
(package private) static org.apache.hadoop.hbase.client.Connection	connection2
org.junit.rules.TestName	name

Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

admin, CONF_WITH_LOCALFS, conf1, conf2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, PEER_ID2, row, scopes, SLEEP_TIME, tableName, utility1, utility2, zkw1, zkw2

Constructor Summary

Constructors

Constructor and Description
TestReplicationAdminWithClusters()

Method Summary

Modifier and Type	Method and Description
void	disableNotFullReplication()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testDisableAndEnableReplication()
void	testDisableReplicationForNonExistingTable()
void	testDisableReplicationWhenTableNameAsNull()
void	testEnableReplicationForExplicitSetTableCfs()
void	testEnableReplicationForNonExistingTable()
void	testEnableReplicationForTableWithRegionReplica()
void	testEnableReplicationWhenReplicationNotEnabled()
void	testEnableReplicationWhenSlaveClusterDoesntHaveTable()
void	testEnableReplicationWhenTableDescriptorIsNotSameInClusters()
void	testEnableReplicationWhenTableNameAsNull()
void	testReplicationPeerConfigUpdateCallback()

Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

cleanUp, isSerialPeer, loadData, loadData, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, tearDownBase, waitForReplication

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

connection1

static org.apache.hadoop.hbase.client.Connection connection1

connection2

static org.apache.hadoop.hbase.client.Connection connection2

admin1

static org.apache.hadoop.hbase.client.Admin admin1

admin2

static org.apache.hadoop.hbase.client.Admin admin2

adminExt

static org.apache.hadoop.hbase.client.replication.ReplicationAdmin adminExt

name

public org.junit.rules.TestName name

Constructor Detail

TestReplicationAdminWithClusters

public TestReplicationAdminWithClusters()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

disableNotFullReplication

public void disableNotFullReplication()
                               throws Exception

Throws:

Exception

testEnableReplicationWhenSlaveClusterDoesntHaveTable

public void testEnableReplicationWhenSlaveClusterDoesntHaveTable()
                                                          throws Exception

Throws:

Exception

testEnableReplicationWhenReplicationNotEnabled

public void testEnableReplicationWhenReplicationNotEnabled()
                                                    throws Exception

Throws:

Exception

testEnableReplicationWhenTableDescriptorIsNotSameInClusters

public void testEnableReplicationWhenTableDescriptorIsNotSameInClusters()
                                                                 throws Exception

Throws:

Exception

testDisableAndEnableReplication

public void testDisableAndEnableReplication()
                                     throws Exception

Throws:

Exception

testEnableReplicationForTableWithRegionReplica

public void testEnableReplicationForTableWithRegionReplica()
                                                    throws Exception

Throws:

Exception

testDisableReplicationForNonExistingTable

public void testDisableReplicationForNonExistingTable()
                                               throws Exception

Throws:

Exception

testEnableReplicationForNonExistingTable

public void testEnableReplicationForNonExistingTable()
                                              throws Exception

Throws:

Exception

testDisableReplicationWhenTableNameAsNull

public void testDisableReplicationWhenTableNameAsNull()
                                               throws Exception

Throws:

Exception

testEnableReplicationWhenTableNameAsNull

public void testEnableReplicationWhenTableNameAsNull()
                                              throws Exception

Throws:

Exception

testEnableReplicationForExplicitSetTableCfs

public void testEnableReplicationForExplicitSetTableCfs()
                                                 throws Exception

Throws:

Exception

testReplicationPeerConfigUpdateCallback

public void testReplicationPeerConfigUpdateCallback()
                                             throws Exception

Throws:

Exception