@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
|
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
|
Map<TableName,List<String>> |
getTableCFs()
Get replicable (table, cf-list) map of this peer
|
void |
removeListenerOfPeerConfig(ReplicationPeerConfigListener listener)
Remove a listener when it is closed or terminated
|
void |
trackPeerConfigChanges(ReplicationPeerConfigListener listener)
Setup a callback for chanages to the replication peer config
|
String getId()
ReplicationPeerConfig getPeerConfig()
ReplicationPeer.PeerState getPeerState()
org.apache.hadoop.conf.Configuration getConfiguration()
Map<TableName,List<String>> getTableCFs()
long getPeerBandwidth()
void trackPeerConfigChanges(ReplicationPeerConfigListener listener)
listener
- Listener for config changes, usually a replication endpointvoid removeListenerOfPeerConfig(ReplicationPeerConfigListener listener)
listener
- Listener for config changes, usually a replication endpointCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.