org.apache.hadoop.hbase.test

Class IntegrationTestReplication.VerifyReplicationLoop

java.lang.Object

Configured

org.apache.hadoop.hbase.test.IntegrationTestReplication.VerifyReplicationLoop

Enclosing class:

IntegrationTestReplication

protected class IntegrationTestReplication.VerifyReplicationLoop
extends Configured

The main runner loop for the test. It uses IntegrationTestBigLinkedList for the generation and verification of the linked list. It is heavily based on IntegrationTestBigLinkedList.Loop

Field Summary

Fields

Modifier and Type	Field and Description
protected IntegrationTestReplication.ClusterID	sink
protected IntegrationTestReplication.ClusterID	source

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	VerifyReplicationLoop()

Method Summary

Modifier and Type	Method and Description
int	run(String[] args) The main test runner This test has 4 steps: 1: setupTablesAndReplication 2: generate the data into the source cluster 3: wait for replication to propagate 4: verify that the data is available in the sink cluster
protected void	runGenerator() Run the IntegrationTestBigLinkedList.Generator in the source cluster.
protected void	runVerify(long expectedNumNodes) Run the IntegrationTestBigLinkedList.Verify in the sink cluster.
protected void	setupTablesAndReplication() This tears down any tables that existed from before and rebuilds the tables and schemas on the source cluster.
protected void	waitForReplication()

Methods inherited from class java.lang.Object

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

Field Detail

source

protected IntegrationTestReplication.ClusterID source

sink

protected IntegrationTestReplication.ClusterID sink

Constructor Detail

VerifyReplicationLoop

protected VerifyReplicationLoop()

Method Detail

setupTablesAndReplication

protected void setupTablesAndReplication()
                                  throws Exception

This tears down any tables that existed from before and rebuilds the tables and schemas on the source cluster. It then sets up replication from the source to the sink cluster by using the ReplicationAdmin connection.

Throws:

Exception

waitForReplication

protected void waitForReplication()
                           throws Exception

Throws:

Exception

runGenerator

protected void runGenerator()
                     throws Exception

Run the IntegrationTestBigLinkedList.Generator in the source cluster. This assumes that the tables have been setup via setupTablesAndReplication.

Throws:

Exception

runVerify

protected void runVerify(long expectedNumNodes)
                  throws Exception

Run the IntegrationTestBigLinkedList.Verify in the sink cluster. If replication is working properly the data written at the source cluster should be available in the sink cluster after a reasonable gap

Parameters:

expectedNumNodes - the number of nodes we are expecting to see in the sink cluster

Throws:

Exception

run

public int run(String[] args)
        throws Exception

The main test runner This test has 4 steps: 1: setupTablesAndReplication 2: generate the data into the source cluster 3: wait for replication to propagate 4: verify that the data is available in the sink cluster

Parameters:

args - should be empty

Returns:

0 on success

Throws:

Exception - on an error