public static class VerifyReplication.Verifier extends TableMapper<ImmutableBytesWritable,Put>
| Modifier and Type | Class and Description |
|---|---|
static class |
VerifyReplication.Verifier.Counters |
| Constructor and Description |
|---|
VerifyReplication.Verifier() |
| 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.
|
public void map(ImmutableBytesWritable row, Result value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException
map in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Put>row - The current table row key.value - The columns.context - The current context.IOException - When something is broken with the data.protected void cleanup(org.apache.hadoop.mapreduce.Mapper.Context context)
cleanup in class org.apache.hadoop.mapreduce.Mapper<ImmutableBytesWritable,Result,ImmutableBytesWritable,Put>Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.