ReplicationPeerZKImpl (Apache HBase 1.4.11 API)

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

All Implemented Interfaces:: Closeable, AutoCloseable, Abortable, ReplicationPeer

@InterfaceAudience.Private
public class ReplicationPeerZKImpl
extends ReplicationStateZKBase
implements ReplicationPeer, Abortable, Closeable

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`class`	`ReplicationPeerZKImpl.PeerConfigTracker` Tracker for PeerConfigNode of this peer
`class`	`ReplicationPeerZKImpl.PeerStateTracker` Tracker for state of this peer

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationPeer
ReplicationPeer.PeerState

Field Summary
- Fields inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase
  abortable, DISABLED_ZNODE_BYTES, ENABLED_ZNODE_BYTES, hfileRefsZNode, ourClusterKey, peerStateNodeName, peersZNode, queuesZNode, replicationZNode, tableCFsNodeName, zookeeper, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

Constructor Summary

Constructors
Constructor and Description
`ReplicationPeerZKImpl(ZooKeeperWatcher zkWatcher, org.apache.hadoop.conf.Configuration conf, String id, ReplicationPeerConfig peerConfig, Abortable abortable)` Constructor that takes all the objects required to communicate with the specified peer, except for the region server addresses.

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`abort(String why, Throwable e)` Abort the server or client.
`void`	`close()`
`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
`boolean`	`isAborted()` Check if the server or client was aborted.
`static boolean`	`isStateEnabled(byte[] bytes)` Parse the raw data from ZK to get a peer's state
`void`	`removeListenerOfPeerConfig(ReplicationPeerConfigListener listener)` Remove a listener when it is closed or terminated
`void`	`startPeerConfigTracker(ZooKeeperWatcher zookeeper, String peerConfigNode)` start a table-cfs tracker to listen the (table, cf-list) map change
`void`	`startStateTracker(String peerStateNode)` start a state tracker to check whether this peer is enabled or not
`void`	`trackPeerConfigChanges(ReplicationPeerConfigListener listener)` Setup a callback for chanages to the replication peer config

Methods inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase
getListOfReplicatorsZK, getPeerNode, getPeerStateNode, getTableCFsNode, isPeerPath, peerExists, toByteArray

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - ReplicationPeerZKImpl
```
public ReplicationPeerZKImpl(ZooKeeperWatcher zkWatcher,
                     org.apache.hadoop.conf.Configuration conf,
                     String id,
                     ReplicationPeerConfig peerConfig,
                     Abortable abortable)
                      throws ReplicationException
```
    Constructor that takes all the objects required to communicate with the specified peer, except for the region server addresses.
    
    Parameters:
    conf - configuration object to this peer
    id - string representation of this peer's identifier
    peerConfig - configuration for the replication peer
    
    Throws:
    
    ReplicationException
- Method Detail
  - startStateTracker
```
public void startStateTracker(String peerStateNode)
                       throws org.apache.zookeeper.KeeperException
```
    start a state tracker to check whether this peer is enabled or not
    
    Parameters:
    peerStateNode - path to zk node which stores peer state
    
    Throws:
    
    org.apache.zookeeper.KeeperException
  - startPeerConfigTracker
```
public void startPeerConfigTracker(ZooKeeperWatcher zookeeper,
                          String peerConfigNode)
                            throws org.apache.zookeeper.KeeperException
```
    start a table-cfs tracker to listen the (table, cf-list) map change
    
    Parameters:
    zookeeper -
    peerConfigNode - path to zk node which stores table-cfs
    
    Throws:
    
    org.apache.zookeeper.KeeperException
  - getPeerState
```
public ReplicationPeer.PeerState getPeerState()
```
    Description copied from interface: ReplicationPeer
    
    Returns the state of the peer
    
    Specified by:
    
    getPeerState in interface ReplicationPeer
    
    Returns:
    the enabled state
  - getId
```
public String getId()
```
    Get the identifier of this peer
    
    Specified by:
    
    getId in interface ReplicationPeer
    
    Returns:
    string representation of the id (short)
  - getPeerConfig
```
public ReplicationPeerConfig getPeerConfig()
```
    Get the peer config object
    
    Specified by:
    
    getPeerConfig in interface ReplicationPeer
    
    Returns:
    the ReplicationPeerConfig for this peer
  - getConfiguration
```
public org.apache.hadoop.conf.Configuration getConfiguration()
```
    Get the configuration object required to communicate with this peer
    
    Specified by:
    
    getConfiguration in interface ReplicationPeer
    
    Returns:
    configuration object
  - getTableCFs
```
public Map<TableName,List<String>> getTableCFs()
```
    Get replicable (table, cf-list) map of this peer
    
    Specified by:
    
    getTableCFs in interface ReplicationPeer
    
    Returns:
    the replicable (table, cf-list) map
  - getPeerBandwidth
```
public long getPeerBandwidth()
```
    Description copied from interface: ReplicationPeer
    
    Get the per node bandwidth upper limit for this peer
    
    Specified by:
    
    getPeerBandwidth in interface ReplicationPeer
    
    Returns:
    the bandwidth up limit
  - trackPeerConfigChanges
```
public void trackPeerConfigChanges(ReplicationPeerConfigListener listener)
```
    Description copied from interface: ReplicationPeer
    
    Setup a callback for chanages to the replication peer config
    
    Specified by:
    
    trackPeerConfigChanges in interface ReplicationPeer
    
    Parameters:
    listener - Listener for config changes, usually a replication endpoint
  - removeListenerOfPeerConfig
```
public void removeListenerOfPeerConfig(ReplicationPeerConfigListener listener)
```
    Description copied from interface: ReplicationPeer
    
    Remove a listener when it is closed or terminated
    
    Specified by:
    
    removeListenerOfPeerConfig in interface ReplicationPeer
    
    Parameters:
    listener - Listener for config changes, usually a replication endpoint
  - abort
```
public void abort(String why,
         Throwable e)
```
    Description copied from interface: Abortable
    
    Abort the server or client.
    
    Specified by:
    
    abort in interface Abortable
    
    Parameters:
    why - Why we're aborting.
    e - Throwable that caused abort. Can be null.
  - isAborted
```
public boolean isAborted()
```
    Description copied from interface: Abortable
    
    Check if the server or client was aborted.
    
    Specified by:
    
    isAborted in interface Abortable
    
    Returns:
    true if the server or client was aborted, false otherwise
  - close
```
public void close()
           throws IOException
```
    Specified by:
    
    close in interface Closeable
    
    Specified by:
    
    close in interface AutoCloseable
    
    Throws:
    
    IOException
  - isStateEnabled
```
public static boolean isStateEnabled(byte[] bytes)
                              throws DeserializationException
```
    Parse the raw data from ZK to get a peer's state
    
    Parameters:
    bytes - raw ZK data
    
    Returns:
    True if the passed in bytes are those of a pb serialized ENABLED state.
    
    Throws:
    
    DeserializationException

Class ReplicationPeerZKImpl

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.replication.ReplicationPeer

Field Summary

Fields inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase

Constructor Summary

Method Summary

Methods inherited from class org.apache.hadoop.hbase.replication.ReplicationStateZKBase

Methods inherited from class java.lang.Object

Constructor Detail

ReplicationPeerZKImpl

Method Detail

startStateTracker

startPeerConfigTracker

getPeerState

getId

getPeerConfig

getConfiguration

getTableCFs

getPeerBandwidth

trackPeerConfigChanges

removeListenerOfPeerConfig

abort

isAborted

close

isStateEnabled