org.apache.hadoop.hbase.replication

Class TestReplicationSmallTests

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationSmallTests

public class TestReplicationSmallTests
extends TestReplicationBase

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
TestReplicationSmallTests()

Method Summary

Modifier and Type	Method and Description
void	setUp()
void	testAddAndRemoveClusters() Integration test for TestReplicationAdmin, removes and re-add a peer cluster
void	testCompactionWALEdits() Test for HBASE-9038, Replication.scopeWALEdits would NPE if it wasn't filtering out the compaction WALEdit
void	testDeleteTypes() Verify that version and column delete marker types are replicated correctly.
void	testDisableEnable() Test disable/enable replication, trying to insert, make sure nothing's replicated, enable it, the insert should be replicated
void	testLoading() Do a more intense version testSmallBatch, one that will trigger wal rolling and other non-trivial code paths
void	testReplicationStatus() Test for HBASE-9531 put a few rows into htable1, which should be replicated to htable2 create a ClusterStatus instance 'status' from HBaseAdmin test : status.getLoad(server).getReplicationLoadSourceList() test : status.getLoad(server).getReplicationLoadSink() * @throws Exception
void	testSimplePutDelete() Add a row, check it's replicated, delete it, check's gone
void	testSmallBatch() Try a small batch upload using the write buffer, check it's replicated
void	testVerifyListReplicatedTable() Test for HBASE-8663 Create two new Tables with colfamilies enabled for replication then run ReplicationAdmin.listReplicated().
void	testVerifyRepJob() Do a small loading into a table, make sure the data is really the same, then run the VerifyReplication job to check the results.

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

setUpBeforeClass, tearDownAfterClass

Methods inherited from class java.lang.Object

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

Constructor Detail

TestReplicationSmallTests

public TestReplicationSmallTests()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

testDeleteTypes

public void testDeleteTypes()
                     throws Exception

Verify that version and column delete marker types are replicated correctly.

Throws:

Exception

testSimplePutDelete

public void testSimplePutDelete()
                         throws Exception

Add a row, check it's replicated, delete it, check's gone

Throws:

Exception

testSmallBatch

public void testSmallBatch()
                    throws Exception

Try a small batch upload using the write buffer, check it's replicated

Throws:

Exception

testDisableEnable

public void testDisableEnable()
                       throws Exception

Test disable/enable replication, trying to insert, make sure nothing's replicated, enable it, the insert should be replicated

Throws:

Exception

testAddAndRemoveClusters

public void testAddAndRemoveClusters()
                              throws Exception

Integration test for TestReplicationAdmin, removes and re-add a peer cluster

Throws:

Exception

testLoading

public void testLoading()
                 throws Exception

Do a more intense version testSmallBatch, one that will trigger wal rolling and other non-trivial code paths

Throws:

Exception

testVerifyRepJob

public void testVerifyRepJob()
                      throws Exception

Do a small loading into a table, make sure the data is really the same, then run the VerifyReplication job to check the results. Do a second comparison where all the cells are different.

Throws:

Exception

testCompactionWALEdits

public void testCompactionWALEdits()
                            throws Exception

Test for HBASE-9038, Replication.scopeWALEdits would NPE if it wasn't filtering out the compaction WALEdit

Throws:

Exception

testVerifyListReplicatedTable

public void testVerifyListReplicatedTable()
                                   throws Exception

Test for HBASE-8663 Create two new Tables with colfamilies enabled for replication then run ReplicationAdmin.listReplicated(). Finally verify the table:colfamilies. Note: TestReplicationAdmin is a better place for this testing but it would need mocks.

Throws:

Exception

testReplicationStatus

public void testReplicationStatus()
                           throws Exception

Test for HBASE-9531 put a few rows into htable1, which should be replicated to htable2 create a ClusterStatus instance 'status' from HBaseAdmin test : status.getLoad(server).getReplicationLoadSourceList() test : status.getLoad(server).getReplicationLoadSink() * @throws Exception

Throws:

Exception