Package org.apache.hadoop.hbase.mapreduce.replication

Class VerifyReplicationRecompareRunnable

java.lang.Object

org.apache.hadoop.hbase.mapreduce.replication.VerifyReplicationRecompareRunnable

All Implemented Interfaces:

Runnable

@Private
public class VerifyReplicationRecompareRunnable
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.hadoop.mapreduce.Mapper.Context	context
private final String	delimiter
private static final org.slf4j.Logger	LOG
private final VerifyReplication.Verifier.Counters	originalCounter
private final int	reCompareBackoffExponent
private final int	reCompareTries
private Result	replicatedResult
private final Table	replicatedTable
private final byte[]	row
private final int	sleepMsBeforeReCompare
private Result	sourceResult
private final Table	sourceTable
private final Scan	tableScan
private final boolean	verbose

Constructor Summary

Constructors

Constructor	Description
VerifyReplicationRecompareRunnable(org.apache.hadoop.mapreduce.Mapper.Context context, Result sourceResult, Result replicatedResult, VerifyReplication.Verifier.Counters originalCounter, String delimiter, Scan tableScan, Table sourceTable, Table replicatedTable, int reCompareTries, int sleepMsBeforeReCompare, int reCompareBackoffExponent, boolean verbose)

Method Summary

Modifier and Type	Method	Description
void	fail()
private boolean	fetchLatestRows(Get get)
private void	incrementOriginalAndBadCounter()
private boolean	matches(Result original, Result updated, VerifyReplication.Verifier.Counters failCounter)
void	run()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

context

private final org.apache.hadoop.mapreduce.Mapper.Context context

originalCounter

private final VerifyReplication.Verifier.Counters originalCounter

delimiter

private final String delimiter

row

private final byte[] row

tableScan

private final Scan tableScan

sourceTable

private final Table sourceTable

replicatedTable

private final Table replicatedTable

reCompareTries

private final int reCompareTries

sleepMsBeforeReCompare

private final int sleepMsBeforeReCompare

reCompareBackoffExponent

private final int reCompareBackoffExponent

verbose

private final boolean verbose

sourceResult

private Result sourceResult

replicatedResult

private Result replicatedResult

Constructor Details

VerifyReplicationRecompareRunnable

public VerifyReplicationRecompareRunnable(org.apache.hadoop.mapreduce.Mapper.Context context,
 Result sourceResult,
 Result replicatedResult,
 VerifyReplication.Verifier.Counters originalCounter,
 String delimiter,
 Scan tableScan,
 Table sourceTable,
 Table replicatedTable,
 int reCompareTries,
 int sleepMsBeforeReCompare,
 int reCompareBackoffExponent,
 boolean verbose)

Method Details

run

public void run()

Specified by:

run in interface Runnable

fail

public void fail()

fetchLatestRows

private boolean fetchLatestRows(Get get)
                         throws IOException

Throws:

IOException

matches

private boolean matches(Result original,
 Result updated,
 VerifyReplication.Verifier.Counters failCounter)

incrementOriginalAndBadCounter

private void incrementOriginalAndBadCounter()