public static class TestSerialReplicationEndpoint.TestEndpoint 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 |
---|---|
private static BlockingQueue<org.apache.hadoop.hbase.wal.WAL.Entry> |
entryQueue |
REPLICATION_DROP_ON_DELETED_COLUMN_FAMILY_KEY, REPLICATION_DROP_ON_DELETED_TABLE_KEY
Constructor and Description |
---|
TestEndpoint() |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<Integer> |
asyncReplicate(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
int ordinal,
int timeout) |
boolean |
canReplicateToSameCluster() |
static List<org.apache.hadoop.hbase.wal.WAL.Entry> |
getEntries() |
int |
getNumSinks() |
static void |
reset() |
doStop, filterNotExistColumnFamilyEdits, filterNotExistTableEdits, init, isNoSuchColumnFamilyException, isPeerEnabled, isTableNotFoundException, replicate, replicateEntries
abort, chooseSinks, createConnection, disconnect, doStart, fetchSlavesAddresses, getPeerUUID, getReplicationSink, isAborted, reportBadSink, reportSinkSuccess, start, stop
getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, isStarting, peerConfigUpdated
addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString
private static final BlockingQueue<org.apache.hadoop.hbase.wal.WAL.Entry> entryQueue
public TestEndpoint()
public static void reset()
public static List<org.apache.hadoop.hbase.wal.WAL.Entry> getEntries()
public boolean canReplicateToSameCluster()
canReplicateToSameCluster
in interface org.apache.hadoop.hbase.replication.ReplicationEndpoint
canReplicateToSameCluster
in class org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
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
public int getNumSinks()
getNumSinks
in class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.