org.apache.hadoop.hbase.replication

Class ReplicationTrackerZKImpl

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationTrackerZKImpl

All Implemented Interfaces:

ReplicationTracker

@InterfaceAudience.Private
public class ReplicationTrackerZKImpl
extends Object
implements ReplicationTracker

This class is a ZooKeeper implementation of the ReplicationTracker interface. This class is responsible for handling replication events that are defined in the ReplicationListener interface.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ReplicationTrackerZKImpl.OtherRegionServerWatcher Watcher used to be notified of the other region server's death in the local cluster.

Field Summary

Fields

Modifier and Type	Field and Description
private Abortable	abortable
private List<ReplicationListener>	listeners
private static org.slf4j.Logger	LOG
private ArrayList<String>	otherRegionServers
private Stoppable	stopper
private ZKWatcher	zookeeper

Constructor Summary

Constructors

Constructor and Description
ReplicationTrackerZKImpl(ZKWatcher zookeeper, Abortable abortable, Stoppable stopper)

Method Summary

Modifier and Type	Method and Description
List<String>	getListOfRegionServers() Return a snapshot of the current region servers.
private List<String>	getRegisteredRegionServers(boolean watch) Get a list of all the other region servers in this cluster and set a watch
private String	getZNodeName(String fullPath) Extracts the znode name of a peer cluster from a ZK path
private boolean	refreshOtherRegionServersList(boolean watch) Reads the list of region servers from ZK and atomically clears our local view of it and replaces it with the updated list.
void	registerListener(ReplicationListener listener) Register a replication listener to receive replication events.
void	removeListener(ReplicationListener listener)

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

zookeeper

private final ZKWatcher zookeeper

abortable

private final Abortable abortable

stopper

private final Stoppable stopper

listeners

private final List<ReplicationListener> listeners

otherRegionServers

private final ArrayList<String> otherRegionServers

Constructor Detail

ReplicationTrackerZKImpl

public ReplicationTrackerZKImpl(ZKWatcher zookeeper,
                                Abortable abortable,
                                Stoppable stopper)

Method Detail

registerListener

public void registerListener(ReplicationListener listener)

Description copied from interface: ReplicationTracker

Register a replication listener to receive replication events.

Specified by:

registerListener in interface ReplicationTracker

removeListener

public void removeListener(ReplicationListener listener)

Specified by:

removeListener in interface ReplicationTracker

getListOfRegionServers

public List<String> getListOfRegionServers()

Return a snapshot of the current region servers.

Specified by:

getListOfRegionServers in interface ReplicationTracker

Returns:

List of region servers.

getZNodeName

private String getZNodeName(String fullPath)

Extracts the znode name of a peer cluster from a ZK path

Parameters:

fullPath - Path to extract the id from

Returns:

the id or an empty string if path is invalid

refreshOtherRegionServersList

private boolean refreshOtherRegionServersList(boolean watch)

Reads the list of region servers from ZK and atomically clears our local view of it and replaces it with the updated list.

Returns:

true if the local list of the other region servers was updated with the ZK data (even if it was empty), false if the data was missing in ZK

getRegisteredRegionServers

private List<String> getRegisteredRegionServers(boolean watch)

Get a list of all the other region servers in this cluster and set a watch

Returns:

a list of server nanes