@InterfaceAudience.Private public class VerifyReplicationRecompareRunnable extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.mapreduce.Mapper.Context |
context |
private String |
delimiter |
private static org.slf4j.Logger |
LOG |
private VerifyReplication.Verifier.Counters |
originalCounter |
private int |
reCompareBackoffExponent |
private int |
reCompareTries |
private Result |
replicatedResult |
private Table |
replicatedTable |
private byte[] |
row |
private int |
sleepMsBeforeReCompare |
private Result |
sourceResult |
private Table |
sourceTable |
private Scan |
tableScan |
private boolean |
verbose |
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
void |
fail() |
private boolean |
fetchLatestRows(Get get) |
private void |
incrementOriginalAndBadCounter() |
private boolean |
matches(Result original,
Result updated,
VerifyReplication.Verifier.Counters failCounter) |
void |
run() |
private static final org.slf4j.Logger LOG
private final org.apache.hadoop.mapreduce.Mapper.Context context
private final VerifyReplication.Verifier.Counters originalCounter
private final byte[] row
private final Table sourceTable
private final Table replicatedTable
private final int reCompareTries
private final int sleepMsBeforeReCompare
private final int reCompareBackoffExponent
private final boolean verbose
private Result sourceResult
private Result replicatedResult
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)
public void fail()
private boolean fetchLatestRows(Get get) throws IOException
IOException
private boolean matches(Result original, Result updated, VerifyReplication.Verifier.Counters failCounter)
private void incrementOriginalAndBadCounter()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.