org.apache.hadoop.hbase.replication.regionserver

Class TestReplicator.FailureInjectingReplicationEndpointForTest

java.lang.Object

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

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint

org.apache.hadoop.hbase.replication.regionserver.TestReplicator.ReplicationEndpointForTest

org.apache.hadoop.hbase.replication.regionserver.TestReplicator.FailureInjectingReplicationEndpointForTest

All Implemented Interfaces:

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

Enclosing class:

TestReplicator

public static class TestReplicator.FailureInjectingReplicationEndpointForTest
extends TestReplicator.ReplicationEndpointForTest

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestReplicator.FailureInjectingReplicationEndpointForTest.FailureInjectingBlockingInterface
class	TestReplicator.FailureInjectingReplicationEndpointForTest.FailureInjectingReplicatorForTest

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.regionserver.TestReplicator.ReplicationEndpointForTest

TestReplicator.ReplicationEndpointForTest.ReplicatorForTest

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint

org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint.Replicator

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.PeerRegionServerListener

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

Constructors

Constructor and Description
FailureInjectingReplicationEndpointForTest()

Method Summary

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint.Replicator	createReplicator(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int ordinal)

Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.TestReplicator.ReplicationEndpointForTest

await, getBatchCount, getEntriesCount, pause, replicate, resume, setBatchCount, setEntriesCount

Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint

doStop, init, isPeerEnabled, sleepForRetries

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

abort, disconnect, doStart, fetchSlavesAddresses, getLastRegionServerUpdate, getPeerUUID, getRegionServers, getZkw, isAborted, reconnect, setRegionServers, start, stop

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

canReplicateToSameCluster, getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, isStarting, peerConfigUpdated

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

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, 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 Detail

FailureInjectingReplicationEndpointForTest

public FailureInjectingReplicationEndpointForTest()

Method Detail

createReplicator

protected org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint.Replicator createReplicator(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
                                                                                                                            int ordinal)

Overrides:

createReplicator in class TestReplicator.ReplicationEndpointForTest