org.apache.hadoop.hbase.replication

Class TestReplicationEndpoint

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationEndpoint

public class TestReplicationEndpoint
extends TestReplicationBase

Tests ReplicationSource and ReplicationEndpoint interactions

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestReplicationEndpoint.ReplicationEndpointForTest
static class	TestReplicationEndpoint.ReplicationEndpointReturningFalse
static class	TestReplicationEndpoint.ReplicationEndpointWithWALEntryFilter

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
TestReplicationEndpoint()

Method Summary

Modifier and Type	Method and Description
void	setup()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testCustomReplicationEndpoint()
void	testReplicationEndpointReturnsFalseOnReplicate()
void	testWALEntryFilterFromReplicationEndpoint()

Methods inherited from class java.lang.Object

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

Constructor Detail

TestReplicationEndpoint

public TestReplicationEndpoint()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws java.lang.Exception

Throws:

java.lang.Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws java.lang.Exception

Throws:

java.lang.Exception

setup

public void setup()
           throws FailedLogCloseException,
                  java.io.IOException

Throws:

FailedLogCloseException

java.io.IOException

testCustomReplicationEndpoint

public void testCustomReplicationEndpoint()
                                   throws java.lang.Exception

Throws:

java.lang.Exception

testReplicationEndpointReturnsFalseOnReplicate

public void testReplicationEndpointReturnsFalseOnReplicate()
                                                    throws java.lang.Exception

Throws:

java.lang.Exception

testWALEntryFilterFromReplicationEndpoint

public void testWALEntryFilterFromReplicationEndpoint()
                                               throws java.lang.Exception

Throws:

java.lang.Exception