Field Detail

• replicatedScanner

  private ResultScanner replicatedScanner

• currentCompareRowInPeerTable

  private Result currentCompareRowInPeerTable

• replicatedTable

  private Table replicatedTable

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.

• logFailRowAndIncreaseCounter

  private void logFailRowAndIncreaseCounter(org.apache.hadoop.mapreduce.Mapper.Context context,
                                  VerifyReplication.Verifier.Counters counter,
                                  Result row)

• cleanup

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

  Overrides:

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