@InterfaceAudience.Private public class ReplicationSyncUp extends org.apache.hadoop.conf.Configured implements org.apache.hadoop.util.Tool
hbase org.apache.hadoop.hbase.replication.regionserver.ReplicationSyncUp
Modifier and Type | Class and Description |
---|---|
private static class |
ReplicationSyncUp.DummyServer |
static class |
ReplicationSyncUp.ReplicationSyncUpToolInfo |
Modifier and Type | Field and Description |
---|---|
static String |
INFO_DIR |
static String |
INFO_FILE |
private static long |
SLEEP_TIME |
Constructor and Description |
---|
ReplicationSyncUp() |
Modifier and Type | Method and Description |
---|---|
private void |
addMissingReplicationQueues(ReplicationQueueStorage storage,
ServerName regionServer,
Set<String> peerIds) |
private void |
addMissingReplicationQueues(ReplicationQueueStorage storage,
Set<ServerName> regionServers,
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) |
public static final String INFO_DIR
public static final String INFO_FILE
private static final long SLEEP_TIME
public ReplicationSyncUp()
private Set<ServerName> listRegionServers(org.apache.hadoop.fs.FileSystem walFs, org.apache.hadoop.fs.Path walDir) throws IOException
IOException
private void addMissingReplicationQueues(ReplicationQueueStorage storage, ServerName regionServer, Set<String> peerIds) throws ReplicationException
ReplicationException
private void addMissingReplicationQueues(ReplicationQueueStorage storage, Set<ServerName> regionServers, Set<String> peerIds) throws ReplicationException
ReplicationException
private void claimReplicationQueues(ReplicationSourceManager mgr, Set<ServerName> regionServers) throws ReplicationException, org.apache.zookeeper.KeeperException, IOException
ReplicationException
org.apache.zookeeper.KeeperException
IOException
private void writeInfoFile(org.apache.hadoop.fs.FileSystem fs, boolean isForce) throws IOException
IOException
private static void printUsageAndExit(String message, int exitCode)
private static void printUsage(String message)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.