Package org.apache.hadoop.hbase.replication

Class TestReplicationEndpoint.ReplicationEndpointWithWALEntryFilter

java.lang.Object

org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest

org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointWithWALEntryFilter

All Implemented Interfaces:

org.apache.hadoop.hbase.replication.ReplicationEndpoint, org.apache.hadoop.hbase.replication.ReplicationPeerConfigListener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

Enclosing class:

TestReplicationEndpoint

public static class TestReplicationEndpoint.ReplicationEndpointWithWALEntryFilter
extends TestReplicationEndpoint.ReplicationEndpointForTest

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

org.apache.hadoop.hbase.replication.ReplicationEndpoint.Context, org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext

Nested classes/interfaces inherited from interface org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.Listener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static AtomicReference<Exception>	ex

Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest

contructedCount, lastEntries, replicateCount, startedCount, stoppedCount, uuid

Fields inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor	Description
ReplicationEndpointWithWALEntryFilter()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.hbase.replication.WALEntryFilter	getWALEntryfilter()
boolean	replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)

Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest

canReplicateToSameCluster, doStart, doStop, getPeerUUID, start, stop

Methods inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, init, isStarting, peerConfigUpdated

Methods inherited from class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning

Field Details

ex

static AtomicReference<Exception> ex

Constructor Details

ReplicationEndpointWithWALEntryFilter

public ReplicationEndpointWithWALEntryFilter()

Method Details

replicate

public boolean replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)

Specified by:

replicate in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

Overrides:

replicate in class TestReplicationEndpoint.ReplicationEndpointForTest

getWALEntryfilter

public org.apache.hadoop.hbase.replication.WALEntryFilter getWALEntryfilter()

Specified by:

getWALEntryfilter in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

Overrides:

getWALEntryfilter in class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint