public static class TestReplicationEndpoint.ReplicationEndpointForTest extends org.apache.hadoop.hbase.replication.BaseReplicationEndpoint
Modifier and Type | Field and Description |
---|---|
(package private) static AtomicInteger |
contructedCount |
(package private) static List<org.apache.hadoop.hbase.wal.WAL.Entry> |
lastEntries |
(package private) static AtomicInteger |
replicateCount |
(package private) static AtomicInteger |
startedCount |
(package private) static AtomicInteger |
stoppedCount |
(package private) static UUID |
uuid |
Constructor and Description |
---|
ReplicationEndpointForTest() |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
UUID |
getPeerUUID() |
boolean |
replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext) |
void |
start() |
void |
stop() |
canReplicateToSameCluster, getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, init, isStarting, peerConfigUpdated
addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString
static AtomicInteger contructedCount
static AtomicInteger startedCount
static AtomicInteger stoppedCount
static AtomicInteger replicateCount
static volatile List<org.apache.hadoop.hbase.wal.WAL.Entry> lastEntries
public ReplicationEndpointForTest()
public UUID getPeerUUID()
public boolean replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)
public void start()
public void stop()
protected void doStart()
doStart
in class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService
protected void doStop()
doStop
in class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.