org.apache.hadoop.hbase.replication

Class HBaseReplicationEndpoint

java.lang.Object

org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

org.apache.hadoop.hbase.replication.BaseReplicationEndpoint

org.apache.hadoop.hbase.replication.HBaseReplicationEndpoint

All Implemented Interfaces:

Abortable, ReplicationEndpoint, ReplicationPeerConfigListener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

Direct Known Subclasses:

HBaseInterClusterReplicationEndpoint, RegionReplicaReplicationEndpoint

@InterfaceAudience.Private
public abstract class HBaseReplicationEndpoint
extends BaseReplicationEndpoint
implements Abortable

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

Nested classes/interfaces inherited from interface org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service

org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.Listener, org.apache.hbase.thirdparty.com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field and Description
private long	lastRegionServerUpdate
private static org.slf4j.Logger	LOG
private List<ServerName>	regionServers
private ZKWatcher	zkw

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(String why, Throwable e) Abort the server or client.
protected void	disconnect()
protected void	doStart()
protected void	doStop()
protected static 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.
UUID	getPeerUUID() Returns a UUID of the provided peer id.
List<ServerName>	getRegionServers() Get a list of all the addresses of all the available region servers for this peer cluster, or an empty list if no region servers available at peer cluster.
protected ZKWatcher	getZkw() Get the ZK connection to this peer
boolean	isAborted() Check if the server or client was aborted.
protected void	reconnect(org.apache.zookeeper.KeeperException ke) A private method used to re-establish a zookeeper session with a peer cluster.
(package private) void	reloadZkWatcher() Closes the current ZKW (if not null) and creates a new one
void	setRegionServers(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 org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, doCancelStart, failureCause, isRunning, notifyFailed, notifyStarted, notifyStopped, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

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

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

zkw

private ZKWatcher zkw

regionServers

private List<ServerName> regionServers

lastRegionServerUpdate

private long lastRegionServerUpdate

Constructor Detail

HBaseReplicationEndpoint

public HBaseReplicationEndpoint()

Method Detail

disconnect

protected void disconnect()

reconnect

protected void reconnect(org.apache.zookeeper.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.

Specified by:

start in interface ReplicationEndpoint

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.

Specified by:

stop in interface ReplicationEndpoint

doStart

protected void doStart()

Specified by:

doStart in class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class org.apache.hbase.thirdparty.com.google.common.util.concurrent.AbstractService

getPeerUUID

public 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.

Specified by:

getPeerUUID in interface ReplicationEndpoint

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

reloadZkWatcher

void reloadZkWatcher()
              throws IOException

Closes the current ZKW (if not null) and creates a new one

Throws:

IOException - If anything goes wrong connecting

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

fetchSlavesAddresses

protected static List<ServerName> fetchSlavesAddresses(ZKWatcher zkw)
                                                throws org.apache.zookeeper.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:

org.apache.zookeeper.KeeperException

getRegionServers

public List<ServerName> getRegionServers()

Get a list of all the addresses of all the available region servers for this peer cluster, or an empty list if no region servers available at peer cluster.

Returns:

list of addresses

setRegionServers

public void setRegionServers(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.