public static class TestReplicator.FailureInjectingReplicationEndpointForTest extends TestReplicator.ReplicationEndpointForTest
Modifier and Type | Class and Description |
---|---|
(package private) static class |
TestReplicator.FailureInjectingReplicationEndpointForTest.FailureInjectingBlockingInterface |
class |
TestReplicator.FailureInjectingReplicationEndpointForTest.FailureInjectingReplicatorForTest |
TestReplicator.ReplicationEndpointForTest.ReplicatorForTest
org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint.Replicator
org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.PeerRegionServerListener
Constructor and Description |
---|
FailureInjectingReplicationEndpointForTest() |
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) |
await, getBatchCount, getEntriesCount, pause, replicate, resume, setBatchCount, setEntriesCount
doStop, init, isPeerEnabled, sleepForRetries
abort, disconnect, doStart, fetchSlavesAddresses, getLastRegionServerUpdate, getPeerUUID, getRegionServers, getZkw, isAborted, reconnect, setRegionServers, start, stop
canReplicateToSameCluster, getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, isStarting, peerConfigUpdated
addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString
public FailureInjectingReplicationEndpointForTest()
protected org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint.Replicator createReplicator(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int ordinal)
createReplicator
in class TestReplicator.ReplicationEndpointForTest
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.