public static class TestReplicationEndpoint.InterClusterReplicationEndpointForTest extends org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint
org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.PeerRegionServerListener, org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.SinkPeer
Modifier and Type | Field and Description |
---|---|
(package private) static boolean |
failedOnce |
(package private) static AtomicInteger |
replicateCount |
REPLICATION_DROP_ON_DELETED_COLUMN_FAMILY_KEY, REPLICATION_DROP_ON_DELETED_TABLE_KEY
Constructor and Description |
---|
InterClusterReplicationEndpointForTest() |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<Integer> |
asyncReplicate(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
int ordinal,
int timeout) |
boolean |
replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext) |
doStop, init, isNoSuchColumnFamilyException, isPeerEnabled, isTableNotFoundException, replicateEntries
abort, chooseSinks, createConnection, disconnect, doStart, fetchSlavesAddresses, getNumSinks, getPeerUUID, getReplicationSink, getSinkServers, 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
static AtomicInteger replicateCount
static boolean failedOnce
public InterClusterReplicationEndpointForTest()
public boolean replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)
replicate
in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint
replicate
in class org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint
protected CompletableFuture<Integer> asyncReplicate(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, int ordinal, int timeout)
asyncReplicate
in class org.apache.hadoop.hbase.replication.regionserver.HBaseInterClusterReplicationEndpoint
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.