private static class TestHBaseReplicationEndpoint.DummyHBaseReplicationEndpoint extends org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint
org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.PeerRegionServerListener, org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint.SinkPeer
Modifier and Type | Field and Description |
---|---|
(package private) List<org.apache.hadoop.hbase.ServerName> |
regionServers |
Modifier | Constructor and Description |
---|---|
private |
DummyHBaseReplicationEndpoint() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.client.AsyncClusterConnection |
createConnection(org.apache.hadoop.conf.Configuration conf) |
List<org.apache.hadoop.hbase.ServerName> |
fetchSlavesAddresses() |
boolean |
replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext) |
void |
setRegionServers(List<org.apache.hadoop.hbase.ServerName> regionServers) |
abort, chooseSinks, disconnect, doStart, doStop, getNumSinks, getPeerUUID, getReplicationSink, getSinkServers, init, 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
List<org.apache.hadoop.hbase.ServerName> regionServers
private DummyHBaseReplicationEndpoint()
public void setRegionServers(List<org.apache.hadoop.hbase.ServerName> regionServers)
public List<org.apache.hadoop.hbase.ServerName> fetchSlavesAddresses()
fetchSlavesAddresses
in class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint
public boolean replicate(org.apache.hadoop.hbase.replication.ReplicationEndpoint.ReplicateContext replicateContext)
public org.apache.hadoop.hbase.client.AsyncClusterConnection createConnection(org.apache.hadoop.conf.Configuration conf) throws IOException
createConnection
in class org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.