org.apache.hadoop.hbase.mapreduce.replication

Class VerifyReplication.Verifier

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,KEYOUT,VALUEOUT>

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

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

org.apache.hadoop.mapreduce.Mapper.Context

Constructor Summary

Constructors

Constructor and Description
VerifyReplication.Verifier()

Method Summary

Methods

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

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

run, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

VerifyReplication.Verifier

public VerifyReplication.Verifier()

Method Detail

map

public void map(ImmutableBytesWritable row,
       Result value,
       org.apache.hadoop.mapreduce.Mapper.Context context)
         throws IOException

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

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Put>

Parameters:

row - The current table row key.

value - The columns.

context - The current context.

Throws:

IOException - When something is broken with the data.

cleanup

protected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context)

Overrides:

cleanup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Put>