Package org.apache.cassandra.repair

Class Validator

java.lang.Object

org.apache.cassandra.repair.Validator

All Implemented Interfaces:

Runnable

public class Validator
extends Object
implements Runnable

Handles the building of a merkle tree for a column family. Lifecycle: 1. prepare() - Initialize tree with samples. 2. add() - 0 or more times, to add hashes to the tree. 3. complete() - Enqueues any operations that were blocked waiting for a valid tree.

Field Summary

Fields

Modifier and Type	Field	Description
final SharedContext	ctx
final RepairJobDesc	desc
final InetAddressAndPort	initiator
final boolean	isIncremental
final long	nowInSec
final ValidationState	state
TopPartitionTracker.Collector	topPartitionCollector

Constructor Summary

Constructors

Constructor	Description
Validator(SharedContext ctx, ValidationState state, long nowInSec, boolean evenTreeDistribution, boolean isIncremental, PreviewKind previewKind)
Validator(SharedContext ctx, ValidationState state, long nowInSec, boolean isIncremental, PreviewKind previewKind)
Validator(ValidationState state, long nowInSec, boolean isIncremental, PreviewKind previewKind)
Validator(ValidationState state, long nowInSec, PreviewKind previewKind)

Method Summary

Modifier and Type	Method	Description
void	add(UnfilteredRowIterator partition)	Called (in order) for every row present in the CF.
void	complete()	Registers the newly created tree for rendezvous in Stage.ANTIENTROPY.
void	fail(Throwable e)	Called when some error during the validation happened.
boolean	findCorrectRange(Token t)
PreviewKind	getPreviewKind()
void	prepare(ColumnFamilyStore cfs, MerkleTrees trees, TopPartitionTracker.Collector topPartitionCollector)
void	run()	Called after the validation lifecycle to respond with the now valid tree.

Methods inherited from class java.lang.Object

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

Field Details

desc

public final RepairJobDesc desc

initiator

public final InetAddressAndPort initiator

nowInSec

public final long nowInSec

isIncremental

public final boolean isIncremental

ctx

public final SharedContext ctx

state

public final ValidationState state

topPartitionCollector

public TopPartitionTracker.Collector topPartitionCollector

Constructor Details

Validator

public Validator(ValidationState state,
 long nowInSec,
 PreviewKind previewKind)

Validator

public Validator(SharedContext ctx,
 ValidationState state,
 long nowInSec,
 boolean isIncremental,
 PreviewKind previewKind)

Validator

public Validator(ValidationState state,
 long nowInSec,
 boolean isIncremental,
 PreviewKind previewKind)

Validator

public Validator(SharedContext ctx,
 ValidationState state,
 long nowInSec,
 boolean evenTreeDistribution,
 boolean isIncremental,
 PreviewKind previewKind)

Method Details

prepare

public void prepare(ColumnFamilyStore cfs,
 MerkleTrees trees,
 TopPartitionTracker.Collector topPartitionCollector)

add

public void add(UnfilteredRowIterator partition)

Called (in order) for every row present in the CF. Hashes the row, and adds it to the tree being built.

Parameters:

partition - Partition to add hash

findCorrectRange

public boolean findCorrectRange(Token t)

complete

public void complete()

Registers the newly created tree for rendezvous in Stage.ANTIENTROPY.

fail

public void fail(Throwable e)

Called when some error during the validation happened. This sends RepairStatus to inform the initiator that the validation has failed. The actual reason for failure should be looked up in the log of the host calling this function.

run

public void run()

Called after the validation lifecycle to respond with the now valid tree. Runs in Stage.ANTIENTROPY.

Specified by:

run in interface Runnable

getPreviewKind

public PreviewKind getPreviewKind()