Package org.apache.hadoop.hbase.replication.regionserver

Class TestSerialReplicationEndpoint

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestSerialReplicationEndpoint

public class TestSerialReplicationEndpoint
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestSerialReplicationEndpoint.TestEndpoint

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	CONF
private static org.apache.hadoop.hbase.client.Connection	CONN
private static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor	Description
TestSerialReplicationEndpoint()

Method Summary

Modifier and Type	Method	Description
private String	getZKClusterKey()
static void	setUp()
static void	tearDown()
private void	testHBaseReplicationEndpoint(String tableNameStr, String peerId, boolean isSerial)
void	testParallelReplicate()
void	testSerialReplicate()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

UTIL

private static HBaseTestingUtility UTIL

CONF

private static org.apache.hadoop.conf.Configuration CONF

CONN

private static org.apache.hadoop.hbase.client.Connection CONN

Constructor Details

TestSerialReplicationEndpoint

public TestSerialReplicationEndpoint()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

getZKClusterKey

private String getZKClusterKey()

testHBaseReplicationEndpoint

private void testHBaseReplicationEndpoint(String tableNameStr,
 String peerId,
 boolean isSerial)
                                   throws IOException

Throws:

IOException

testSerialReplicate

public void testSerialReplicate()
                         throws Exception

Throws:

Exception

testParallelReplicate

public void testParallelReplicate()
                           throws Exception

Throws:

Exception