Package org.apache.hadoop.hbase

Class RegionReplicationLagEvaluation

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.RegionReplicationLagEvaluation

All Implemented Interfaces:

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

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

A tool to evaluating the lag between primary replica and secondary replica.

It simply adds a row to the primary replica, and then check how long before we can read it from the secondary replica.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FAMILY_NAME
private org.apache.hadoop.hbase.metrics.impl.FastLongHistogram	histogram
private static final org.slf4j.Logger	LOG
private static final org.apache.hbase.thirdparty.org.apache.commons.cli.Options	OPTIONS
static final String	QUALIFIER_NAME
static final int	ROW_LENGTH
static final String	TABLE_NAME
static final int	VALUE_LENGTH

Constructor Summary

Constructors

Constructor	Description
RegionReplicationLagEvaluation()

Method Summary

Modifier and Type	Method	Description
private void	checkLag(org.apache.hadoop.hbase.client.Table table, int rlen, int vlen, int rows)
private void	createTable(org.apache.hadoop.hbase.client.Admin admin, org.apache.hadoop.hbase.TableName tableName)
private void	exec(org.apache.hadoop.hbase.TableName tableName, int rlen, int vlen, int rows)
(package private) org.apache.hadoop.hbase.metrics.impl.FastLongHistogram	getHistogram()
static void	main(String[] args)
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

TABLE_NAME

public static final String TABLE_NAME

See Also:

• Constant Field Values

FAMILY_NAME

public static final String FAMILY_NAME

See Also:

• Constant Field Values

QUALIFIER_NAME

public static final String QUALIFIER_NAME

See Also:

• Constant Field Values

VALUE_LENGTH

public static final int VALUE_LENGTH

See Also:

• Constant Field Values

ROW_LENGTH

public static final int ROW_LENGTH

See Also:

• Constant Field Values

OPTIONS

private static final org.apache.hbase.thirdparty.org.apache.commons.cli.Options OPTIONS

histogram

private org.apache.hadoop.hbase.metrics.impl.FastLongHistogram histogram

Constructor Details

RegionReplicationLagEvaluation

public RegionReplicationLagEvaluation()

Method Details

getHistogram

org.apache.hadoop.hbase.metrics.impl.FastLongHistogram getHistogram()

run

public int run(String[] args)
        throws Exception

Specified by:

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

Throws:

Exception

createTable

private void createTable(org.apache.hadoop.hbase.client.Admin admin,
 org.apache.hadoop.hbase.TableName tableName)
                  throws IOException

Throws:

IOException

checkLag

private void checkLag(org.apache.hadoop.hbase.client.Table table,
 int rlen,
 int vlen,
 int rows)
               throws IOException

Throws:

IOException

exec

private void exec(org.apache.hadoop.hbase.TableName tableName,
 int rlen,
 int vlen,
 int rows)
           throws IOException

Throws:

IOException

main

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

Throws:

Exception