org.apache.hadoop.hbase.replication.regionserver

Class DumpReplicationQueues

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.replication.regionserver.DumpReplicationQueues

All Implemented Interfaces:

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

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

Provides information about the existing states of replication, replication peers and queues. Usage: hbase org.apache.hadoop.hbase.replication.regionserver.DumpReplicationQueues [args] Arguments: --distributed Polls each RS to dump information about the queue --hdfs Reports HDFS usage by the replication queues (note: can be overestimated).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	DumpReplicationQueues.DumpOptions
private static class	DumpReplicationQueues.WarnOnlyAbortable
private static class	DumpReplicationQueues.WarnOnlyStoppable

Field Summary

Fields

Modifier and Type	Field and Description
private List<String>	deadRegionServers
private List<String>	deletedQueues
private static org.slf4j.Logger	LOG
private long	numWalsNotFound
private org.apache.hbase.thirdparty.com.google.common.util.concurrent.AtomicLongMap<String>	peersQueueSize
private long	totalSizeOfWALs

Constructor Summary

Constructors

Constructor and Description
DumpReplicationQueues()

Method Summary

Modifier and Type	Method and Description
String	dumpPeersState(List<ReplicationPeerDescription> peers)
String	dumpQueues(ClusterConnection connection, ZKWatcher zkw, Set<String> peerIds, boolean hdfs)
private int	dumpReplicationQueues(DumpReplicationQueues.DumpOptions opts)
String	dumpReplicationSummary()
private String	formatQueue(String regionserver, ReplicationQueues replicationQueues, ReplicationQueueInfo queueInfo, String queueId, List<String> wals, boolean isDeleted, boolean hdfs)
private long	getTotalWALSize(org.apache.hadoop.fs.FileSystem fs, List<String> wals, String server) return total size in bytes from a list of WALs
static void	main(String[] args) Main
(package private) static DumpReplicationQueues.DumpOptions	parseOpts(Queue<String> args)
protected void	printUsage()
protected static void	printUsage(String message)
protected static void	printUsage(String className, String message)
protected static void	printUsageAndExit(String message, int exitCode)
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

LOG

private static final org.slf4j.Logger LOG

deadRegionServers

private List<String> deadRegionServers

deletedQueues

private List<String> deletedQueues

peersQueueSize

private org.apache.hbase.thirdparty.com.google.common.util.concurrent.AtomicLongMap<String> peersQueueSize

totalSizeOfWALs

private long totalSizeOfWALs

numWalsNotFound

private long numWalsNotFound

Constructor Detail

DumpReplicationQueues

public DumpReplicationQueues()

Method Detail

parseOpts

static DumpReplicationQueues.DumpOptions parseOpts(Queue<String> args)

main

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

Main

Parameters:

args -

Throws:

Exception

run

public int run(String[] args)
        throws Exception

Specified by:

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

Throws:

Exception

printUsage

protected void printUsage()

printUsage

protected static void printUsage(String message)

printUsage

protected static void printUsage(String className,
                                 String message)

printUsageAndExit

protected static void printUsageAndExit(String message,
                                        int exitCode)

dumpReplicationQueues

private int dumpReplicationQueues(DumpReplicationQueues.DumpOptions opts)
                           throws Exception

Throws:

Exception

dumpReplicationSummary

public String dumpReplicationSummary()

dumpPeersState

public String dumpPeersState(List<ReplicationPeerDescription> peers)
                      throws Exception

Throws:

Exception

dumpQueues

public String dumpQueues(ClusterConnection connection,
                         ZKWatcher zkw,
                         Set<String> peerIds,
                         boolean hdfs)
                  throws Exception

Throws:

Exception

formatQueue

private String formatQueue(String regionserver,
                           ReplicationQueues replicationQueues,
                           ReplicationQueueInfo queueInfo,
                           String queueId,
                           List<String> wals,
                           boolean isDeleted,
                           boolean hdfs)
                    throws Exception

Throws:

Exception

getTotalWALSize

private long getTotalWALSize(org.apache.hadoop.fs.FileSystem fs,
                             List<String> wals,
                             String server)
                      throws IOException

return total size in bytes from a list of WALs

Throws:

IOException