org.apache.hadoop.hbase.test

Class IntegrationTestReplication.VerifyReplicationLoop

java.lang.Object

org.apache.hadoop.conf.Configured

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

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

Enclosing class:

IntegrationTestReplication

protected class IntegrationTestReplication.VerifyReplicationLoop
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

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
(package private) IntegrationTestBigLinkedList	integrationTestBigLinkedList
private org.slf4j.Logger	LOG
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 org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Detail

LOG

private final org.slf4j.Logger LOG

source

protected IntegrationTestReplication.ClusterID source

sink

protected IntegrationTestReplication.ClusterID sink

integrationTestBigLinkedList

IntegrationTestBigLinkedList integrationTestBigLinkedList

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

Specified by:

run in interface org.apache.hadoop.util.Tool

Parameters:

args - should be empty

Returns:

0 on success

Throws:

Exception - on an error