Class TestReplicationEndpoint.ReplicationEndpointReturningFalse
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.ReplicationEndpointReturningFalse
- 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.ReplicationEndpointReturningFalse
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
Modifier and TypeFieldDescription(package private) static int
(package private) static AtomicReference<Exception>
(package private) static AtomicBoolean
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
-
Method Summary
Modifier and TypeMethodDescriptionboolean
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, getWALEntryfilter, 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
-
COUNT
-
ex
-
replicated
-
-
Constructor Details
-
ReplicationEndpointReturningFalse
public ReplicationEndpointReturningFalse()
-
-
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 classTestReplicationEndpoint.ReplicationEndpointForTest
-