public class TestReplicationEndpoint extends TestReplicationBase
Modifier and Type | Class and Description |
---|---|
static class |
TestReplicationEndpoint.ReplicationEndpointForTest |
static class |
TestReplicationEndpoint.ReplicationEndpointReturningFalse |
static class |
TestReplicationEndpoint.ReplicationEndpointWithWALEntryFilter |
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 and Description |
---|
TestReplicationEndpoint() |
Modifier and Type | Method and Description |
---|---|
void |
setup() |
static void |
setUpBeforeClass() |
static void |
tearDownAfterClass() |
void |
testCustomReplicationEndpoint() |
void |
testReplicationEndpointReturnsFalseOnReplicate() |
void |
testWALEntryFilterFromReplicationEndpoint() |
public static void setUpBeforeClass() throws java.lang.Exception
java.lang.Exception
public static void tearDownAfterClass() throws java.lang.Exception
java.lang.Exception
public void setup() throws FailedLogCloseException, java.io.IOException
FailedLogCloseException
java.io.IOException
public void testCustomReplicationEndpoint() throws java.lang.Exception
java.lang.Exception
public void testReplicationEndpointReturnsFalseOnReplicate() throws java.lang.Exception
java.lang.Exception
public void testWALEntryFilterFromReplicationEndpoint() throws java.lang.Exception
java.lang.Exception