@InterfaceAudience.Private class SyncReplicationPeerMappingManager extends Object
TODO: now only support include table options.
Modifier and Type | Field and Description |
---|---|
private ConcurrentMap<TableName,String> |
table2PeerId |
Constructor and Description |
---|
SyncReplicationPeerMappingManager() |
Modifier and Type | Method and Description |
---|---|
(package private) void |
add(String peerId,
ReplicationPeerConfig peerConfig) |
(package private) String |
getPeerId(TableName tableName) |
(package private) void |
remove(String peerId,
ReplicationPeerConfig peerConfig) |
private final ConcurrentMap<TableName,String> table2PeerId
SyncReplicationPeerMappingManager()
void add(String peerId, ReplicationPeerConfig peerConfig)
void remove(String peerId, ReplicationPeerConfig peerConfig)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.