@InterfaceAudience.LimitedPrivate(value="Replication") public interface ReplicationPeer
Modifier and Type | Interface and Description |
---|---|
static class |
ReplicationPeer.PeerState
State of the peer, whether it is enabled or not
|
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.conf.Configuration |
getConfiguration()
Get the configuration object required to communicate with this peer
|
String |
getId()
Get the identifier of this peer
|
Set<String> |
getNamespaces()
Get replicable namespace set of this peer
|
long |
getPeerBandwidth()
Get the per node bandwidth upper limit for this peer
|
ReplicationPeerConfig |
getPeerConfig()
Get the peer config object
|
ReplicationPeer.PeerState |
getPeerState()
Returns the state of the peer by reading local cache.
|
Map<TableName,List<String>> |
getTableCFs()
Get replicable (table, cf-list) map of this peer
|
default boolean |
isPeerEnabled()
Test whether the peer is enabled.
|
void |
registerPeerConfigListener(ReplicationPeerConfigListener listener)
Register a peer config listener to catch the peer config change event.
|
default void |
trackPeerConfigChanges(ReplicationPeerConfigListener listener)
Deprecated.
since 2.1.0 and will be removed in 4.0.0. Use
registerPeerConfigListener(ReplicationPeerConfigListener) instead. |
ReplicationPeer.PeerState getPeerState()
default boolean isPeerEnabled()
true
if enabled, otherwise false
.ReplicationPeerConfig getPeerConfig()
org.apache.hadoop.conf.Configuration getConfiguration()
Map<TableName,List<String>> getTableCFs()
Set<String> getNamespaces()
long getPeerBandwidth()
void registerPeerConfigListener(ReplicationPeerConfigListener listener)
listener
- listener to catch the peer config change event.@Deprecated default void trackPeerConfigChanges(ReplicationPeerConfigListener listener)
registerPeerConfigListener(ReplicationPeerConfigListener)
instead.Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.