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.ReplicateContextNested 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
FieldsModifier and TypeFieldDescription(package private) static int(package private) static AtomicReference<Exception>(package private) static AtomicBooleanFields inherited from class org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest
contructedCount, lastEntries, replicateCount, startedCount, stoppedCount, uuidFields inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanreplicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext) Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationEndpoint.ReplicationEndpointForTest
canReplicateToSameCluster, doStart, doStop, getPeerUUID, start, stopMethods inherited from class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, init, isStarting, peerConfigUpdatedMethods 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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods 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:
replicatein interfaceorg.apache.hadoop.hbase.replication.ReplicationEndpoint- Overrides:
replicatein classTestReplicationEndpoint.ReplicationEndpointForTest
-