Package 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

@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	Description
private static final class	ReplicationSyncUp.DummyServer
static class	ReplicationSyncUp.ReplicationSyncUpToolInfo

Field Summary

Fields

Modifier and Type	Field	Description
static final String	INFO_DIR
static final String	INFO_FILE
private static final long	SLEEP_TIME

Constructor Summary

Constructors

Constructor	Description
ReplicationSyncUp()

Method Summary

Modifier and Type	Method	Description
private void	addMissingReplicationQueues(ReplicationQueueStorage storage, Set<ServerName> regionServers, Set<String> peerIds)
private void	addMissingReplicationQueues(ReplicationQueueStorage storage, ServerName regionServer, Set<String> peerIds)
private void	claimReplicationQueues(ReplicationSourceManager mgr, Set<ServerName> regionServers)
private Set<ServerName>	listRegionServers(org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walDir)
static void	main(String[] args)	Main program
private static boolean	parseOpts(String[] args)
private static void	printUsage(String message)
private static void	printUsageAndExit(String message, int exitCode)
int	run(String[] args)
private void	writeInfoFile(org.apache.hadoop.fs.FileSystem fs, boolean isForce)

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 Details

INFO_DIR

public static final String INFO_DIR

See Also:

• Constant Field Values

INFO_FILE

public static final String INFO_FILE

See Also:

• Constant Field Values

SLEEP_TIME

private static final long SLEEP_TIME

See Also:

• Constant Field Values

Constructor Details

ReplicationSyncUp

public ReplicationSyncUp()

Method Details

main

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

Main program

Throws:

Exception

listRegionServers

private Set<ServerName> listRegionServers(org.apache.hadoop.fs.FileSystem walFs,
 org.apache.hadoop.fs.Path walDir)
                                   throws IOException

Throws:

IOException

addMissingReplicationQueues

private void addMissingReplicationQueues(ReplicationQueueStorage storage,
 ServerName regionServer,
 Set<String> peerIds)
                                  throws ReplicationException

Throws:

ReplicationException

addMissingReplicationQueues

private void addMissingReplicationQueues(ReplicationQueueStorage storage,
 Set<ServerName> regionServers,
 Set<String> peerIds)
                                  throws ReplicationException

Throws:

ReplicationException

claimReplicationQueues

private void claimReplicationQueues(ReplicationSourceManager mgr,
 Set<ServerName> regionServers)
                             throws ReplicationException,
org.apache.zookeeper.KeeperException,
IOException

Throws:

ReplicationException

org.apache.zookeeper.KeeperException

IOException

writeInfoFile

private void writeInfoFile(org.apache.hadoop.fs.FileSystem fs,
 boolean isForce)
                    throws IOException

Throws:

IOException

parseOpts

private static boolean parseOpts(String[] args)

printUsageAndExit

private static void printUsageAndExit(String message,
 int exitCode)

printUsage

private static void printUsage(String message)

run

public int run(String[] args)
        throws Exception

Specified by:

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

Throws:

Exception