public class DumpReplicationQueues
extends Configured
Constructor and Description |
---|
DumpReplicationQueues() |
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) |
public static void main(java.lang.String[] args) throws java.lang.Exception
args
- java.lang.Exception
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
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)
public java.lang.String dumpReplicationSummary()
public java.lang.String dumpPeersState(java.util.List<ReplicationPeerDescription> peers) throws java.lang.Exception
java.lang.Exception
public java.lang.String dumpQueues(ClusterConnection connection, ZKWatcher zkw, java.util.Set<java.lang.String> peerIds, boolean hdfs) throws java.lang.Exception
java.lang.Exception