org.apache.hadoop.hbase.replication.regionserver

Class DumpReplicationQueues

java.lang.Object

Configured

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

public class DumpReplicationQueues
extends Configured

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

Constructor Summary

Constructors

Constructor and Description
DumpReplicationQueues()

Method Summary

Modifier and Type	Method and Description
java.lang.String	dumpPeersState(java.util.List<ReplicationPeerDescription> peers)
java.lang.String	dumpQueues(ClusterConnection connection, ZKWatcher zkw, java.util.Set<java.lang.String> peerIds, boolean hdfs)
java.lang.String	dumpReplicationSummary()
static void	main(java.lang.String[] args) Main
protected void	printUsage()
protected static void	printUsage(java.lang.String message)
protected static void	printUsage(java.lang.String className, java.lang.String message)
protected static void	printUsageAndExit(java.lang.String message, int exitCode)
int	run(java.lang.String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

DumpReplicationQueues

public DumpReplicationQueues()

Method Detail

main

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

Main

Parameters:

args -

Throws:

java.lang.Exception

run

public int run(java.lang.String[] args)
        throws java.lang.Exception

Throws:

java.lang.Exception

printUsage

protected void printUsage()

printUsage

protected static void printUsage(java.lang.String message)

printUsage

protected static void printUsage(java.lang.String className,
                                 java.lang.String message)

printUsageAndExit

protected static void printUsageAndExit(java.lang.String message,
                                        int exitCode)

dumpReplicationSummary

public java.lang.String dumpReplicationSummary()

dumpPeersState

public java.lang.String dumpPeersState(java.util.List<ReplicationPeerDescription> peers)
                                throws java.lang.Exception

Throws:

java.lang.Exception

dumpQueues

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

Throws:

java.lang.Exception