Package org.apache.cassandra.service

Class ActiveRepairService.ParentRepairSession

java.lang.Object

org.apache.cassandra.service.ActiveRepairService.ParentRepairSession

Enclosing class:

ActiveRepairService

public static class ActiveRepairService.ParentRepairSession
extends Object

We keep a ParentRepairSession around for the duration of the entire repair, for example, on a 256 token vnode rf=3 cluster we would have 768 RepairSession but only one ParentRepairSession. We use the PRS to avoid anticompacting the sstables 768 times, instead we take all repaired ranges at the end of the repair and anticompact once.

Field Summary

Fields

Modifier and Type	Field	Description
final InetAddressAndPort	coordinator
final AtomicBoolean	hasSnapshots
final boolean	isGlobal
final boolean	isIncremental
final PreviewKind	previewKind
final long	repairedAt

Constructor Summary

Constructors

Constructor	Description
ParentRepairSession(InetAddressAndPort coordinator, List<ColumnFamilyStore> columnFamilyStores, Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)

Method Summary

Modifier and Type	Method	Description
Collection<ColumnFamilyStore>	getColumnFamilyStores()
Keyspace	getKeyspace()
Set<Range<Token>>	getRanges()
Set<TableId>	getTableIds()
boolean	isPreview()
boolean	setHasSnapshots()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

isIncremental

public final boolean isIncremental

isGlobal

public final boolean isGlobal

repairedAt

public final long repairedAt

coordinator

public final InetAddressAndPort coordinator

previewKind

public final PreviewKind previewKind

hasSnapshots

public final AtomicBoolean hasSnapshots

Constructor Details

ParentRepairSession

public ParentRepairSession(InetAddressAndPort coordinator,
 List<ColumnFamilyStore> columnFamilyStores,
 Collection<Range<Token>> ranges,
 boolean isIncremental,
 long repairedAt,
 boolean isGlobal,
 PreviewKind previewKind)

Method Details

isPreview

public boolean isPreview()

getColumnFamilyStores

public Collection<ColumnFamilyStore> getColumnFamilyStores()

getKeyspace

public Keyspace getKeyspace()

getTableIds

public Set<TableId> getTableIds()

getRanges

public Set<Range<Token>> getRanges()

toString

public String toString()

Overrides:

toString in class Object

setHasSnapshots

public boolean setHasSnapshots()