Package org.apache.cassandra.repair.consistent

Class RepairedState

java.lang.Object

org.apache.cassandra.repair.consistent.RepairedState

public class RepairedState
extends Object

Tracks the repaired state of token ranges per table, and is effectively an in memory representation of the on-disk local incremental repair state. The main purpose of this class is to provide metrics via nodetool repair_admin. To make sure those metrics are accurate, it also determines when a completed IR session can be deleted, which is explained in a bit more detail in LocalSessions#cleanup, by the call to isSuperseded.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RepairedState.Section
static class	RepairedState.Stats

Constructor Summary

Constructors

Constructor	Description
RepairedState()

Method Summary

Modifier and Type	Method	Description
void	add(Collection<Range<Token>> ranges, long repairedAt)
void	addAll(List<org.apache.cassandra.repair.consistent.RepairedState.Level> newLevels)
RepairedState.Stats	getRepairedStats(Collection<Range<Token>> ranges)
long	minRepairedAt(Collection<Range<Token>> ranges)

Methods inherited from class java.lang.Object

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

Constructor Details

RepairedState

public RepairedState()

Method Details

add

public void add(Collection<Range<Token>> ranges,
 long repairedAt)

addAll

public void addAll(List<org.apache.cassandra.repair.consistent.RepairedState.Level> newLevels)

minRepairedAt

public long minRepairedAt(Collection<Range<Token>> ranges)

getRepairedStats

public RepairedState.Stats getRepairedStats(Collection<Range<Token>> ranges)