Class TestVerifyCellsReplicationEndpoint.EndpointForTest
java.lang.Object
org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService
org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
org.apache.hadoop.hbase.replication.VerifyWALEntriesReplicationEndpoint
org.apache.hadoop.hbase.replication.TestVerifyCellsReplicationEndpoint.EndpointForTest
- 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:
- TestVerifyCellsReplicationEndpoint
public static final class TestVerifyCellsReplicationEndpoint.EndpointForTest
extends org.apache.hadoop.hbase.replication.VerifyWALEntriesReplicationEndpoint
-
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 inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
replicate
(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext) Methods inherited from class org.apache.hadoop.hbase.replication.VerifyWALEntriesReplicationEndpoint
canReplicateToSameCluster, doStart, doStop, getPeerUUID, getWALEntryfilter, 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
-
Constructor Details
-
EndpointForTest
public EndpointForTest()
-
-
Method Details
-
replicate
public boolean replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext) - Specified by:
replicate
in interfaceorg.apache.hadoop.hbase.replication.ReplicationEndpoint
- Overrides:
replicate
in classorg.apache.hadoop.hbase.replication.VerifyWALEntriesReplicationEndpoint
-