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

Class TestSerialReplicationEndpoint

java.lang.Object

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

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
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
private static org.apache.hadoop.conf.Configuration	CONF
private static org.apache.hadoop.hbase.client.Connection	CONN
private static HBaseTestingUtil	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

UTIL

private static HBaseTestingUtil 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

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
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

@Test
public void testSerialReplicate()
                         throws Exception

Throws:

Exception

testParallelReplicate

@Test
public void testParallelReplicate()
                           throws Exception

Throws:

Exception