org.apache.hadoop.hbase.replication

Class TestMasterReplication

java.lang.Object

org.apache.hadoop.hbase.replication.TestMasterReplication

public class TestMasterReplication
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestMasterReplication.CoprocessorCounter Use a coprocessor to count puts and deletes.

Constructor Summary

Constructors

Constructor and Description
TestMasterReplication()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	tearDown()
void	testCyclicReplication1() It tests the replication scenario involving 0 -> 1 -> 0.
void	testCyclicReplication2() Tests the cyclic replication scenario of 0 -> 1 -> 2 -> 0 by adding and deleting rows to a table in each clusters and ensuring that the each of these clusters get the appropriate mutations.
void	testCyclicReplication3() Tests cyclic replication scenario of 0 -> 1 -> 2 -> 1.
void	testHFileCyclicReplication() It tests the replication scenario involving 0 -> 1 -> 0.
void	testHFileMultiSlaveReplication() It tests the multi slave hfile replication scenario involving 0 -> 1, 2.
void	testHFileReplicationForConfiguredTableCfs() It tests the bulk loaded hfile replication scenario to only explicitly specified table column families.
void	testReplicateWALEntryWhenReplicationIsDisabled()

Methods inherited from class java.lang.Object

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

Constructor Detail

TestMasterReplication

public TestMasterReplication()

Method Detail

setUp

public void setUp()
           throws java.lang.Exception

Throws:

java.lang.Exception

testCyclicReplication1

public void testCyclicReplication1()
                            throws java.lang.Exception

It tests the replication scenario involving 0 -> 1 -> 0. It does it by adding and deleting a row to a table in each cluster, checking if it's replicated. It also tests that the puts and deletes are not replicated back to the originating cluster.

Throws:

java.lang.Exception

testHFileCyclicReplication

public void testHFileCyclicReplication()
                                throws java.lang.Exception

It tests the replication scenario involving 0 -> 1 -> 0. It does it by bulk loading a set of HFiles to a table in each cluster, checking if it's replicated.

Throws:

java.lang.Exception

testCyclicReplication2

public void testCyclicReplication2()
                            throws java.lang.Exception

Tests the cyclic replication scenario of 0 -> 1 -> 2 -> 0 by adding and deleting rows to a table in each clusters and ensuring that the each of these clusters get the appropriate mutations. It also tests the grouping scenario where a cluster needs to replicate the edits originating from itself and also the edits that it received using replication from a different cluster. The scenario is explained in HBASE-9158

Throws:

java.lang.Exception

testHFileMultiSlaveReplication

public void testHFileMultiSlaveReplication()
                                    throws java.lang.Exception

It tests the multi slave hfile replication scenario involving 0 -> 1, 2. It does it by bulk loading a set of HFiles to a table in master cluster, checking if it's replicated in its peers.

Throws:

java.lang.Exception

testHFileReplicationForConfiguredTableCfs

public void testHFileReplicationForConfiguredTableCfs()
                                               throws java.lang.Exception

It tests the bulk loaded hfile replication scenario to only explicitly specified table column families. It does it by bulk loading a set of HFiles belonging to both the CFs of table and set only one CF data to replicate.

Throws:

java.lang.Exception

testCyclicReplication3

public void testCyclicReplication3()
                            throws java.lang.Exception

Tests cyclic replication scenario of 0 -> 1 -> 2 -> 1.

Throws:

java.lang.Exception

testReplicateWALEntryWhenReplicationIsDisabled

public void testReplicateWALEntryWhenReplicationIsDisabled()
                                                    throws java.lang.Exception

Throws:

java.lang.Exception

tearDown

public void tearDown()
              throws java.io.IOException

Throws:

java.io.IOException