Package 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

@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). In the new version, we reimplemented the DumpReplicationQueues tool to support obtaining information from replication table.

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private List<String>	deadRegionServers
private List<String>	deletedQueues
private static final 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	Description
DumpReplicationQueues()

Method Summary

Modifier and Type	Method	Description
String	dumpPeersState(List<ReplicationPeerDescription> peers)
String	dumpQueues(Connection connection, Set<String> peerIds, boolean hdfs, org.apache.hadoop.conf.Configuration conf)
private int	dumpReplicationQueues(DumpReplicationQueues.DumpOptions opts)
String	dumpReplicationSummary()
String	dumpReplicationViaTable(Connection connection, org.apache.hadoop.conf.Configuration conf)
private String	formatQueue(ServerName regionServer, Map<String,ReplicationGroupOffset> offsets, List<String> wals, ReplicationQueueId queueId, boolean isDeleted, boolean hdfs)
private long	getTotalWALSize(org.apache.hadoop.fs.FileSystem fs, List<String> wals, ServerName 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 Details

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 Details

DumpReplicationQueues

public DumpReplicationQueues()

Method Details

parseOpts

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

main

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

Main

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

dumpReplicationViaTable

public String dumpReplicationViaTable(Connection connection,
 org.apache.hadoop.conf.Configuration conf)
                               throws ReplicationException,
IOException

Throws:

ReplicationException

IOException

dumpReplicationSummary

public String dumpReplicationSummary()

dumpPeersState

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

Throws:

Exception

dumpQueues

public String dumpQueues(Connection connection,
 Set<String> peerIds,
 boolean hdfs,
 org.apache.hadoop.conf.Configuration conf)
                  throws Exception

Throws:

Exception

formatQueue

private String formatQueue(ServerName regionServer,
 Map<String,ReplicationGroupOffset> offsets,
 List<String> wals,
 ReplicationQueueId queueId,
 boolean isDeleted,
 boolean hdfs)
                    throws Exception

Throws:

Exception

getTotalWALSize

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

return total size in bytes from a list of WALs