public static class TestReplicator.ReplicationEndpointForTest 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 |
---|---|
protected static AtomicInteger |
batchCount |
protected static int |
entriesCount |
private static Object |
latch |
private static AtomicBoolean |
useLatch |
REPLICATION_DROP_ON_DELETED_COLUMN_FAMILY_KEY, REPLICATION_DROP_ON_DELETED_TABLE_KEY
Constructor and Description |
---|
ReplicationEndpointForTest() |
Modifier and Type | Method and Description |
---|---|
protected CompletableFuture<Integer> |
asyncReplicate(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries,
int ordinal,
int timeout) |
static void |
await() |
static int |
getBatchCount() |
static int |
getEntriesCount() |
static void |
pause() |
boolean |
replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext) |
static void |
resume() |
static void |
setBatchCount(int i) |
static void |
setEntriesCount(int i) |
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
protected static AtomicInteger batchCount
protected static int entriesCount
private static AtomicBoolean useLatch
public ReplicationEndpointForTest()
public static void resume()
public static void pause()
public static void await() throws InterruptedException
InterruptedException
public static int getBatchCount()
public static void setBatchCount(int i)
public static int getEntriesCount()
public static void setEntriesCount(int i)
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.