org.apache.hadoop.hbase.replication

Class ReplicationPeerZKImpl

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

Modifier and Type	Field and Description
private org.apache.hadoop.conf.Configuration	conf
private String	id
private static org.slf4j.Logger	LOG
private ReplicationPeerConfig	peerConfig
private ReplicationPeerZKImpl.PeerConfigTracker	peerConfigTracker
private ReplicationPeer.PeerState	peerState
private ReplicationPeerZKImpl.PeerStateTracker	peerStateTracker
private Map<TableName,List<String>>	tableCFs

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(ZKWatcher 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

Modifier and Type	Method and Description
void	abort(String why, Throwable e) Abort the server or client.
void	close()
private boolean	ensurePeerEnabled(String path) Utility method to ensure an ENABLED znode is in place; if not present, we create it.
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
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
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationState.State	parseStateFrom(byte[] bytes)
private ReplicationPeerConfig	readPeerConfig()
private void	readPeerStateZnode()
void	startPeerConfigTracker(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)

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

peerConfig

private ReplicationPeerConfig peerConfig

id

private final String id

peerState

private volatile ReplicationPeer.PeerState peerState

tableCFs

private volatile Map<TableName,List<String>> tableCFs

conf

private final org.apache.hadoop.conf.Configuration conf

peerStateTracker

private ReplicationPeerZKImpl.PeerStateTracker peerStateTracker

peerConfigTracker

private ReplicationPeerZKImpl.PeerConfigTracker peerConfigTracker

Constructor Detail

ReplicationPeerZKImpl

public ReplicationPeerZKImpl(ZKWatcher 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

readPeerStateZnode

private void readPeerStateZnode()
                         throws DeserializationException

Throws:

DeserializationException

startPeerConfigTracker

public void startPeerConfigTracker(String peerConfigNode)
                            throws org.apache.zookeeper.KeeperException

start a table-cfs tracker to listen the (table, cf-list) map change

Parameters:

peerConfigNode - path to zk node which stores table-cfs

Throws:

org.apache.zookeeper.KeeperException

readPeerConfig

private ReplicationPeerConfig readPeerConfig()

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

getNamespaces

public Set<String> getNamespaces()

Get replicable namespace set of this peer

Specified by:

getNamespaces in interface ReplicationPeer

Returns:

the replicable namespaces set

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 upper limit

trackPeerConfigChanges

public void trackPeerConfigChanges(ReplicationPeerConfigListener listener)

Specified by:

trackPeerConfigChanges in interface ReplicationPeer

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

parseStateFrom

private static org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.ReplicationState.State parseStateFrom(byte[] bytes)
                                                                                                                  throws DeserializationException

Parameters:

bytes - Content of a state znode.

Returns:

State parsed from the passed bytes.

Throws:

DeserializationException

ensurePeerEnabled

private boolean ensurePeerEnabled(String path)
                           throws org.apache.zookeeper.KeeperException.NodeExistsException,
                                  org.apache.zookeeper.KeeperException

Utility method to ensure an ENABLED znode is in place; if not present, we create it.

Parameters:

path - Path to znode to check

Returns:

True if we created the znode.

Throws:

org.apache.zookeeper.KeeperException.NodeExistsException

org.apache.zookeeper.KeeperException