public static class TestReplicator.FailureInjectingReplicationEndpointForTest extends TestReplicator.ReplicationEndpointForTest
org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.PeerRegionServerListener, org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.SinkPeer
Modifier and Type | Field and Description |
---|---|
private AtomicBoolean |
failNext |
batchCount, entriesCount
REPLICATION_DROP_ON_DELETED_COLUMN_FAMILY_KEY, REPLICATION_DROP_ON_DELETED_TABLE_KEY
Constructor and Description |
---|
FailureInjectingReplicationEndpointForTest() |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<Integer> |
asyncReplicate(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
int ordinal,
int timeout) |
await, getBatchCount, getEntriesCount, pause, replicate, resume, setBatchCount, setEntriesCount
doStop, filterNotExistColumnFamilyEdits, filterNotExistTableEdits, init, isNoSuchColumnFamilyException, isPeerEnabled, isTableNotFoundException, replicateEntries
abort, chooseSinks, createConnection, disconnect, doStart, fetchSlavesAddresses, getNumSinks, getPeerUUID, getReplicationSink, isAborted, reportBadSink, reportSinkSuccess, start, stop
canReplicateToSameCluster, getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, isStarting, peerConfigUpdated
addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString
private final AtomicBoolean failNext
public FailureInjectingReplicationEndpointForTest()
protected CompletableFuture<Integer> asyncReplicate(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int ordinal, int timeout)
asyncReplicate
in class TestReplicator.ReplicationEndpointForTest
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.