Package org.apache.cassandra.db.repair

Class PendingAntiCompaction

java.lang.Object

org.apache.cassandra.db.repair.PendingAntiCompaction

public class PendingAntiCompaction
extends Object

Performs an anti compaction on a set of tables and token ranges, isolating the unrepaired sstables for a give token range into a pending repair group so they can't be compacted with other sstables while they are being repaired.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PendingAntiCompaction.AcquireResult
static class	PendingAntiCompaction.AcquisitionCallable

Constructor Summary

Constructors

Constructor	Description
PendingAntiCompaction(TimeUUID prsId, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)

Method Summary

Modifier and Type	Method	Description
protected PendingAntiCompaction.AcquisitionCallable	getAcquisitionCallable(ColumnFamilyStore cfs, Set<Range<Token>> ranges, TimeUUID prsId, int acquireRetrySeconds, int acquireSleepMillis)
protected org.apache.cassandra.db.repair.PendingAntiCompaction.AcquisitionCallback	getAcquisitionCallback(TimeUUID prsId, RangesAtEndpoint tokenRanges)
Future<List<Void>>	run()

Methods inherited from class java.lang.Object

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

Constructor Details

PendingAntiCompaction

public PendingAntiCompaction(TimeUUID prsId,
 Collection<ColumnFamilyStore> tables,
 RangesAtEndpoint tokenRanges,
 ExecutorService executor,
 BooleanSupplier isCancelled)

Method Details

run

public Future<List<Void>> run()

getAcquisitionCallable

protected PendingAntiCompaction.AcquisitionCallable getAcquisitionCallable(ColumnFamilyStore cfs,
 Set<Range<Token>> ranges,
 TimeUUID prsId,
 int acquireRetrySeconds,
 int acquireSleepMillis)

getAcquisitionCallback

protected org.apache.cassandra.db.repair.PendingAntiCompaction.AcquisitionCallback getAcquisitionCallback(TimeUUID prsId,
 RangesAtEndpoint tokenRanges)