org.apache.hadoop.hbase.replication.regionserver

Class ReplicationSyncUp

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.replication.regionserver.ReplicationSyncUp

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

@InterfaceAudience.Private
public class ReplicationSyncUp
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

In a scenario of Replication based Disaster/Recovery, when hbase Master-Cluster crashes, this tool is used to sync-up the delta from Master to Slave using the info from ZooKeeper. The tool will run on Master-Cluster, and assume ZK, Filesystem and NetWork still available after hbase crashes

 hbase org.apache.hadoop.hbase.replication.regionserver.ReplicationSyncUp
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	ReplicationSyncUp.DummyServer

Field Summary

Fields

Modifier and Type	Field and Description
private static long	SLEEP_TIME

Constructor Summary

Constructors

Constructor and Description
ReplicationSyncUp()

Method Summary

Modifier and Type	Method and Description
private void	claimReplicationQueues(ZKWatcher zkw, ReplicationSourceManager mgr)
private Set<ServerName>	getLiveRegionServers(ZKWatcher zkw)
static void	main(String[] args) Main program
int	run(String[] args)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

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.conf.Configurable

getConf, setConf

Field Detail

SLEEP_TIME

private static final long SLEEP_TIME

See Also:

Constant Field Values

Constructor Detail

ReplicationSyncUp

public ReplicationSyncUp()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Main program

Throws:

Exception

getLiveRegionServers

private Set<ServerName> getLiveRegionServers(ZKWatcher zkw)
                                      throws org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.KeeperException

claimReplicationQueues

private void claimReplicationQueues(ZKWatcher zkw,
                                    ReplicationSourceManager mgr)
                             throws ReplicationException,
                                    org.apache.zookeeper.KeeperException

Throws:

ReplicationException

org.apache.zookeeper.KeeperException

run

public int run(String[] args)
        throws Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

Exception