Package org.apache.cassandra.db.repair
Class CassandraKeyspaceRepairManager
- java.lang.Object
-
- org.apache.cassandra.db.repair.CassandraKeyspaceRepairManager
-
- All Implemented Interfaces:
KeyspaceRepairManager
public class CassandraKeyspaceRepairManager extends java.lang.Object implements KeyspaceRepairManager
-
-
Constructor Summary
Constructors Constructor Description CassandraKeyspaceRepairManager(Keyspace keyspace)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.google.common.util.concurrent.ListenableFuture
prepareIncrementalRepair(java.util.UUID sessionID, java.util.Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, java.util.concurrent.ExecutorService executor, java.util.function.BooleanSupplier isCancelled)
Isolate the unrepaired ranges of the given tables, and make referenceable by session id.
-
-
-
Constructor Detail
-
CassandraKeyspaceRepairManager
public CassandraKeyspaceRepairManager(Keyspace keyspace)
-
-
Method Detail
-
prepareIncrementalRepair
public com.google.common.util.concurrent.ListenableFuture prepareIncrementalRepair(java.util.UUID sessionID, java.util.Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, java.util.concurrent.ExecutorService executor, java.util.function.BooleanSupplier isCancelled)
Description copied from interface:KeyspaceRepairManager
Isolate the unrepaired ranges of the given tables, and make referenceable by session id. Until each table has been notified that the repair session has been completed, the data associated with the given session id must not be combined with repaired or unrepaired data, or data from other repair sessions.- Specified by:
prepareIncrementalRepair
in interfaceKeyspaceRepairManager
-
-