ReplicationPeersZKImpl (Apache HBase

java.lang.Object
- org.apache.hadoop.hbase.replication.ReplicationStateZKBase
- - org.apache.hadoop.hbase.replication.ReplicationPeersZKImpl

所有已实现的接口:

ReplicationPeers
```
@InterfaceAudience.Private
public class ReplicationPeersZKImpl
extends ReplicationStateZKBase
implements ReplicationPeers
```
This class provides an implementation of the ReplicationPeers interface using Zookeeper. The peers znode contains a list of all peer replication clusters and the current replication state of those clusters. It has one child peer znode for each peer cluster. The peer znode is named with the cluster id provided by the user in the HBase shell. The value of the peer znode contains the peers cluster key provided by the user in the HBase Shell. The cluster key contains a list of zookeeper quorum peers, the client port for the zookeeper quorum, and the base znode for HBase. For example: /hbase/replication/peers/1 [Value: zk1.host.com,zk2.host.com,zk3.host.com:2181:/hbase] /hbase/replication/peers/2 [Value: zk5.host.com,zk6.host.com,zk7.host.com:2181:/hbase] Each of these peer znodes has a child znode that indicates whether or not replication is enabled on that peer cluster. These peer-state znodes do not have child znodes and simply contain a boolean value (i.e. ENABLED or DISABLED). This value is read/maintained by the ReplicationPeer.PeerStateTracker class. For example: /hbase/replication/peers/1/peer-state [Value: ENABLED] Each of these peer znodes has a child znode that indicates which data will be replicated to the peer cluster. These peer-tableCFs znodes do not have child znodes and only have a table/cf list config. This value is read/maintained by the ReplicationPeer.TableCFsTracker class. For example: /hbase/replication/peers/1/tableCFs [Value: "table1; table2:cf1,cf3; table3:cfx,cfy"]

字段概要
- 从类继承的字段 org.apache.hadoop.hbase.replication.ReplicationStateZKBase
  abortable, conf, DISABLED_ZNODE_BYTES, ENABLED_ZNODE_BYTES, ourClusterKey, peerStateNodeName, peersZNode, queuesZNode, replicationZNode, zookeeper

构造器概要

构造器
构造器和说明

ReplicationPeersZKImpl(ZooKeeperWatcher zk, org.apache.hadoop.conf.Configuration conf, Abortable abortable)

构造器
构造器和说明
`ReplicationPeersZKImpl(ZooKeeperWatcher zk, org.apache.hadoop.conf.Configuration conf, Abortable abortable)`

方法概要

方法
限定符和类型	方法和说明
`void`	`addPeer(String id, ReplicationPeerConfig peerConfig, String tableCFs)` Add a new remote slave cluster for replication.
`boolean`	`createAndAddPeer(String peerId)` Attempt to connect to a new remote slave cluster.
`void`	`disablePeer(String id)` Stop the replication to the specified remote slave cluster.
`void`	`enablePeer(String id)` Restart the replication to the specified remote slave cluster.
`Map<String,ReplicationPeerConfig>`	`getAllPeerConfigs()` List the cluster replication configs of all remote slave clusters (whether they are enabled/disabled or connected/disconnected).
`List<String>`	`getAllPeerIds()` List all registered peer clusters and set a watch on their znodes.
`ReplicationPeer`	`getPeer(String peerId)` Returns the ReplicationPeer
`org.apache.hadoop.hbase.util.Pair<ReplicationPeerConfig,org.apache.hadoop.conf.Configuration>`	`getPeerConf(String peerId)` Returns the configuration needed to talk to the remote slave cluster.
`Set<String>`	`getPeerIds()` Returns the set of peerIds defined
`String`	`getPeerTableCFsConfig(String id)` Get the table and column-family list string of the peer from ZK.
`ReplicationPeerConfig`	`getReplicationPeerConfig(String peerId)` Returns a ReplicationPeerConfig from the znode or null for the given peerId.
`boolean`	`getStatusOfPeer(String id)` Get the replication status for the specified connected remote slave cluster.
`boolean`	`getStatusOfPeerFromBackingStore(String id)` Get the replication status for the specified remote slave cluster, which doesn't have to be connected.
`Map<org.apache.hadoop.hbase.TableName,List<String>>`	`getTableCFs(String id)` Get the table and column-family-list map of the peer.
`void`	`init()` Initialize the ReplicationPeers interface.
`boolean`	`peerAdded(String peerId)`
`void`	`peerRemoved(String peerId)`
`void`	`removePeer(String id)` Removes a remote slave cluster and stops the replication to it.
`void`	`setPeerTableCFsConfig(String id, String tableCFsStr)` Set the table and column-family list string of the peer to ZK.

从类继承的方法 org.apache.hadoop.hbase.replication.ReplicationStateZKBase
getListOfReplicators, isPeerPath, peerExists, toByteArray

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 构造器详细资料
  - ReplicationPeersZKImpl
```
public ReplicationPeersZKImpl(ZooKeeperWatcher zk,
                      org.apache.hadoop.conf.Configuration conf,
                      Abortable abortable)
```
- 方法详细资料
  - init
```
public void init()
          throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Initialize the ReplicationPeers interface.
    
    指定者:
    
    init 在接口中 ReplicationPeers
    
    抛出:
    
    ReplicationException
  - addPeer
```
public void addPeer(String id,
           ReplicationPeerConfig peerConfig,
           String tableCFs)
             throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Add a new remote slave cluster for replication.
    
    指定者:
    
    addPeer 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    peerConfig - configuration for the replication slave cluster
    tableCFs - the table and column-family list which will be replicated for this peer or null for all table and column families
    
    抛出:
    
    ReplicationException
  - removePeer
```
public void removePeer(String id)
                throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Removes a remote slave cluster and stops the replication to it.
    
    指定者:
    
    removePeer 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    
    抛出:
    
    ReplicationException
  - enablePeer
```
public void enablePeer(String id)
                throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Restart the replication to the specified remote slave cluster.
    
    指定者:
    
    enablePeer 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    
    抛出:
    
    ReplicationException
  - disablePeer
```
public void disablePeer(String id)
                 throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Stop the replication to the specified remote slave cluster.
    
    指定者:
    
    disablePeer 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    
    抛出:
    
    ReplicationException
  - getPeerTableCFsConfig
```
public String getPeerTableCFsConfig(String id)
                             throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Get the table and column-family list string of the peer from ZK.
    
    指定者:
    
    getPeerTableCFsConfig 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    
    抛出:
    
    ReplicationException
  - setPeerTableCFsConfig
```
public void setPeerTableCFsConfig(String id,
                         String tableCFsStr)
                           throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Set the table and column-family list string of the peer to ZK.
    
    指定者:
    
    setPeerTableCFsConfig 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    tableCFsStr - the table and column-family list which will be replicated for this peer
    
    抛出:
    
    ReplicationException
  - getTableCFs
```
public Map<org.apache.hadoop.hbase.TableName,List<String>> getTableCFs(String id)
                                                                throws IllegalArgumentException
```
    从接口复制的说明: ReplicationPeers
    
    Get the table and column-family-list map of the peer.
    
    指定者:
    
    getTableCFs 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    
    返回:
    the table and column-family list which will be replicated for this peer
    
    抛出:
    
    IllegalArgumentException
  - getStatusOfPeer
```
public boolean getStatusOfPeer(String id)
```
    从接口复制的说明: ReplicationPeers
    
    Get the replication status for the specified connected remote slave cluster. The value might be read from cache, so it is recommended to use ReplicationPeers.getStatusOfPeerFromBackingStore(String) if reading the state after enabling or disabling it.
    
    指定者:
    
    getStatusOfPeer 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    
    返回:
    true if replication is enabled, false otherwise.
  - getStatusOfPeerFromBackingStore
```
public boolean getStatusOfPeerFromBackingStore(String id)
                                        throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Get the replication status for the specified remote slave cluster, which doesn't have to be connected. The state is read directly from the backing store.
    
    指定者:
    
    getStatusOfPeerFromBackingStore 在接口中 ReplicationPeers
    
    参数:
    id - a short that identifies the cluster
    
    返回:
    true if replication is enabled, false otherwise.
    
    抛出:
    
    ReplicationException
  - getAllPeerConfigs
```
public Map<String,ReplicationPeerConfig> getAllPeerConfigs()
```
    从接口复制的说明: ReplicationPeers
    
    List the cluster replication configs of all remote slave clusters (whether they are enabled/disabled or connected/disconnected).
    
    指定者:
    
    getAllPeerConfigs 在接口中 ReplicationPeers
    
    返回:
    A map of peer ids to peer cluster keys
  - getPeer
```
public ReplicationPeer getPeer(String peerId)
```
    从接口复制的说明: ReplicationPeers
    
    Returns the ReplicationPeer
    
    指定者:
    
    getPeer 在接口中 ReplicationPeers
    
    参数:
    peerId - id for the peer
    
    返回:
    ReplicationPeer object
  - getPeerIds
```
public Set<String> getPeerIds()
```
    从接口复制的说明: ReplicationPeers
    
    Returns the set of peerIds defined
    
    指定者:
    
    getPeerIds 在接口中 ReplicationPeers
    
    返回:
    a Set of Strings for peerIds
  - getReplicationPeerConfig
```
public ReplicationPeerConfig getReplicationPeerConfig(String peerId)
                                               throws ReplicationException
```
    Returns a ReplicationPeerConfig from the znode or null for the given peerId.
    
    指定者:
    
    getReplicationPeerConfig 在接口中 ReplicationPeers
    
    参数:
    peerId - a short name that identifies the cluster
    
    返回:
    ReplicationPeerConfig for the peer
    
    抛出:
    
    ReplicationException
  - getPeerConf
```
public org.apache.hadoop.hbase.util.Pair<ReplicationPeerConfig,org.apache.hadoop.conf.Configuration> getPeerConf(String peerId)
                                                                                                          throws ReplicationException
```
    从接口复制的说明: ReplicationPeers
    
    Returns the configuration needed to talk to the remote slave cluster.
    
    指定者:
    
    getPeerConf 在接口中 ReplicationPeers
    
    参数:
    peerId - a short that identifies the cluster
    
    返回:
    the configuration for the peer cluster, null if it was unable to get the configuration
    
    抛出:
    
    ReplicationException
  - getAllPeerIds
```
public List<String> getAllPeerIds()
```
    List all registered peer clusters and set a watch on their znodes.
    
    指定者:
    
    getAllPeerIds 在接口中 ReplicationPeers
    
    返回:
    A list of peer ids
  - peerAdded
```
public boolean peerAdded(String peerId)
                  throws ReplicationException
```
    指定者:
    
    peerAdded 在接口中 ReplicationPeers
    
    抛出:
    
    ReplicationException
  - peerRemoved
```
public void peerRemoved(String peerId)
```
    指定者:
    
    peerRemoved 在接口中 ReplicationPeers
  - createAndAddPeer
```
public boolean createAndAddPeer(String peerId)
                         throws ReplicationException
```
    Attempt to connect to a new remote slave cluster.
    
    参数:
    peerId - a short that identifies the cluster
    
    返回:
    true if a new connection was made, false if no new connection was made.
    
    抛出:
    
    ReplicationException

类 ReplicationPeersZKImpl

字段概要

从类继承的字段 org.apache.hadoop.hbase.replication.ReplicationStateZKBase

构造器概要

方法概要

从类继承的方法 org.apache.hadoop.hbase.replication.ReplicationStateZKBase

从类继承的方法 java.lang.Object

构造器详细资料

ReplicationPeersZKImpl

方法详细资料

init

addPeer

removePeer

enablePeer

disablePeer

getPeerTableCFsConfig

setPeerTableCFsConfig

getTableCFs

getStatusOfPeer

getStatusOfPeerFromBackingStore

getAllPeerConfigs

getPeer

getPeerIds

getReplicationPeerConfig

getPeerConf

getAllPeerIds

peerAdded

peerRemoved

createAndAddPeer