org.apache.hadoop.hbase.replication

Class HBaseReplicationEndpoint

java.lang.Object

AbstractService

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

All Implemented Interfaces:

ReplicationEndpoint

Direct Known Subclasses:

HBaseInterClusterReplicationEndpoint, RegionReplicaReplicationEndpoint

public abstract class HBaseReplicationEndpoint
extends BaseReplicationEndpoint

A BaseReplicationEndpoint for replication endpoints whose target cluster is an HBase cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HBaseReplicationEndpoint.PeerRegionServerListener Tracks changes to the list of region servers in a peer's cluster.

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

ReplicationEndpoint.Context, ReplicationEndpoint.ReplicateContext

Field Summary

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

ctx, REPLICATION_WALENTRYFILTER_CONFIG_KEY

Constructor Summary

Constructors

Constructor and Description
HBaseReplicationEndpoint()

Method Summary

Modifier and Type	Method and Description
void	abort(java.lang.String why, java.lang.Throwable e)
protected void	disconnect()
protected void	doStart()
protected void	doStop()
protected static java.util.List<ServerName>	fetchSlavesAddresses(ZKWatcher zkw) Get the list of all the region servers from the specified peer
long	getLastRegionServerUpdate() Get the timestamp at which the last change occurred to the list of region servers to replicate to.
java.util.UUID	getPeerUUID() Returns a UUID of the provided peer id.
java.util.List<ServerName>	getRegionServers() Get a list of all the addresses of all the region servers for this peer cluster
protected ZKWatcher	getZkw() Get the ZK connection to this peer
boolean	isAborted()
protected void	reconnect(KeeperException ke) A private method used to re-establish a zookeeper session with a peer cluster.
void	setRegionServers(java.util.List<ServerName> regionServers) Set the list of region servers for that peer
void	start() Initiates service startup and returns immediately.
void	stop() If the service is starting or running, this initiates service shutdown and returns immediately.

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

canReplicateToSameCluster, getNamespaceTableCfWALEntryFilter, getScopeWALEntryFilter, getWALEntryfilter, init, isStarting, peerConfigUpdated

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.replication.ReplicationEndpoint

awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, replicate

Constructor Detail

HBaseReplicationEndpoint

public HBaseReplicationEndpoint()

Method Detail

disconnect

protected void disconnect()

reconnect

protected void reconnect(KeeperException ke)

A private method used to re-establish a zookeeper session with a peer cluster.

Parameters:

ke -

start

public void start()

Description copied from interface: ReplicationEndpoint

Initiates service startup and returns immediately. A stopped service may not be restarted. Equivalent of startAsync call in Guava Service.

stop

public void stop()

Description copied from interface: ReplicationEndpoint

If the service is starting or running, this initiates service shutdown and returns immediately. If the service has already been stopped, this method returns immediately without taking action. Equivalent of stopAsync call in Guava Service.

doStart

protected void doStart()

doStop

protected void doStop()

getPeerUUID

public java.util.UUID getPeerUUID()

Description copied from interface: ReplicationEndpoint

Returns a UUID of the provided peer id. Every HBase cluster instance has a persisted associated UUID. If the replication is not performed to an actual HBase cluster (but some other system), the UUID returned has to uniquely identify the connected target system.

Returns:

a UUID or null if the peer cluster does not exist or is not connected.

getZkw

protected ZKWatcher getZkw()

Get the ZK connection to this peer

Returns:

zk connection

abort

public void abort(java.lang.String why,
                  java.lang.Throwable e)

isAborted

public boolean isAborted()

fetchSlavesAddresses

protected static java.util.List<ServerName> fetchSlavesAddresses(ZKWatcher zkw)
                                                          throws KeeperException

Get the list of all the region servers from the specified peer

Parameters:

zkw - zk connection to use

Returns:

list of region server addresses or an empty list if the slave is unavailable

Throws:

KeeperException

getRegionServers

public java.util.List<ServerName> getRegionServers()

Get a list of all the addresses of all the region servers for this peer cluster

Returns:

list of addresses

setRegionServers

public void setRegionServers(java.util.List<ServerName> regionServers)

Set the list of region servers for that peer

Parameters:

regionServers - list of addresses for the region servers

getLastRegionServerUpdate

public long getLastRegionServerUpdate()

Get the timestamp at which the last change occurred to the list of region servers to replicate to.

Returns:

The System.currentTimeMillis at the last time the list of peer region servers changed.