org.apache.hadoop.hbase.mapreduce.replication

Class VerifyReplication.Verifier

java.lang.Object

<any>

org.apache.hadoop.hbase.mapreduce.TableMapper<ImmutableBytesWritable,Put>

org.apache.hadoop.hbase.mapreduce.replication.VerifyReplication.Verifier

Enclosing class:

VerifyReplication

public static class VerifyReplication.Verifier
extends TableMapper<ImmutableBytesWritable,Put>

Map-only comparator for 2 tables

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	VerifyReplication.Verifier.Counters

Constructor Summary

Constructors

Constructor and Description
Verifier()

Method Summary

Modifier and Type	Method and Description
protected void	cleanup(Context context)
void	map(ImmutableBytesWritable row, Result value, Context context) Map method that compares every scanned row with the equivalent from a distant cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

Verifier

public Verifier()

Method Detail

map

public void map(ImmutableBytesWritable row,
                Result value,
                Context context)
         throws java.io.IOException

Map method that compares every scanned row with the equivalent from a distant cluster.

Parameters:

row - The current table row key.

value - The columns.

context - The current context.

Throws:

java.io.IOException - When something is broken with the data.

cleanup

protected void cleanup(Context context)