VerifyReplication (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.conf.Configured
- - org.apache.hadoop.hbase.mapreduce.replication.VerifyReplication

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool
```
public class VerifyReplication
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool
```
This map-only job compares the data from a local table with a remote one. Every cell is compared and must have exactly the same keys (even timestamp) as well as same value. It is possible to restrict the job by time range and families. The peer id that's provided must match the one given when the replication stream was setup.
Two counters are provided, Verifier.Counters.GOODROWS and BADROWS. The reason for a why a row is different is shown in the map's log.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class VerifyReplication.Verifier
Map-only comparator for 2 tables

Nested Classes
Modifier and Type	Class and Description
`static class`	`VerifyReplication.Verifier` Map-only comparator for 2 tables

Field Summary

Fields
Modifier and Type	Field and Description
`(package private) static long`	`endTime`
`(package private) static String`	`families`
`private static org.apache.commons.logging.Log`	`LOG`
`static String`	`NAME`
`private static String`	`PEER_CONFIG_PREFIX`
`(package private) static String`	`peerId`
`(package private) static long`	`startTime`
`(package private) static String`	`tableName`
`(package private) static int`	`versions`

Constructor Summary

Constructors
Constructor and Description

VerifyReplication()

Constructors
Constructor and Description
`VerifyReplication()`

Method Summary

Methods
Modifier and Type	Method and Description
`static org.apache.hadoop.mapreduce.Job`	`createSubmittableJob(org.apache.hadoop.conf.Configuration conf, String[] args)` Sets up the actual job.
`private static boolean`	`doCommandLine(String[] args)`
`private static Pair<ReplicationPeerConfig,org.apache.hadoop.conf.Configuration>`	`getPeerQuorumConfig(org.apache.hadoop.conf.Configuration conf)`
`static void`	`main(String[] args)` Main entry point.
`private static void`	`printUsage(String errorMsg)`
`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.apache.commons.logging.Log LOG

NAME
```
public static final String NAME
```
See Also:
Constant Field Values

PEER_CONFIG_PREFIX

private static final String PEER_CONFIG_PREFIX

See Also:: Constant Field Values

startTime
```
static long startTime
```

endTime
```
static long endTime
```

versions
```
static int versions
```

tableName
```
static String tableName
```

families
```
static String families
```

peerId
```
static String peerId
```

Constructor Detail
- VerifyReplication
```
public VerifyReplication()
```

Method Detail

getPeerQuorumConfig

private static Pair<ReplicationPeerConfig,org.apache.hadoop.conf.Configuration> getPeerQuorumConfig(org.apache.hadoop.conf.Configuration conf)
                                                                                             throws IOException

Throws:: IOException

createSubmittableJob

public static org.apache.hadoop.mapreduce.Job createSubmittableJob(org.apache.hadoop.conf.Configuration conf,
                                                   String[] args)
                                                            throws IOException

Sets up the actual job.

Parameters:: conf - The current configuration.; args - The command line parameters.
Returns:: The newly created job.
Throws:: IOException - When setting up the job fails.

doCommandLine

private static boolean doCommandLine(String[] args)

printUsage

private static void printUsage(String errorMsg)

run
```
public int run(String[] args)
        throws Exception
```
Specified by:

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

Throws:

Exception

main
```
public static void main(String[] args)
                 throws Exception
```
Main entry point.

Parameters:
args - The command line parameters.

Throws:

Exception - When running the job fails.

Class VerifyReplication

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class org.apache.hadoop.conf.Configured

Methods inherited from class java.lang.Object

Methods inherited from interface org.apache.hadoop.conf.Configurable

Field Detail

LOG

NAME

PEER_CONFIG_PREFIX

startTime

endTime

versions

tableName

families

peerId

Constructor Detail

VerifyReplication

Method Detail

getPeerQuorumConfig

createSubmittableJob

doCommandLine

printUsage

run

main