Package org.apache.cassandra.repair
Interface TableRepairManager
-
- All Known Implementing Classes:
CassandraTableRepairManager
public interface TableRepairManager
Table level hook for repair
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ValidationPartitionIterator
getValidationIterator(java.util.Collection<Range<Token>> ranges, java.util.UUID parentId, java.util.UUID sessionID, boolean isIncremental, int nowInSec)
Return a validation iterator for the given parameters.void
incrementalSessionCompleted(java.util.UUID sessionID)
Called when the given incremental session has completed.void
snapshot(java.lang.String name, java.util.Collection<Range<Token>> ranges, boolean force)
For snapshot repairs.java.util.concurrent.Future<?>
submitValidation(java.util.concurrent.Callable<java.lang.Object> validation)
Begin execution of the given validation callable.
-
-
-
Method Detail
-
getValidationIterator
ValidationPartitionIterator getValidationIterator(java.util.Collection<Range<Token>> ranges, java.util.UUID parentId, java.util.UUID sessionID, boolean isIncremental, int nowInSec) throws java.io.IOException
Return a validation iterator for the given parameters. If isIncremental is true, the iterator must only include data previously isolated for repair with the given parentId. nowInSec should determine whether tombstones shouldn be purged or not.- Throws:
java.io.IOException
-
submitValidation
java.util.concurrent.Future<?> submitValidation(java.util.concurrent.Callable<java.lang.Object> validation)
Begin execution of the given validation callable. Which thread pool a validation should run in is an implementation detail.
-
incrementalSessionCompleted
void incrementalSessionCompleted(java.util.UUID sessionID)
Called when the given incremental session has completed. Because of race and failure conditions, implementors should not rely only on receiving calls from this method to determine when a session has ended. Implementors can determine if a session has finished by calling ActiveRepairService.instance.consistent.local.isSessionInProgress. Just because a session has completed doesn't mean it's completed succesfully. So implementors need to consult the repair service at ActiveRepairService.instance.consistent.local.getFinalSessionRepairedAt to get the repairedAt time. If the repairedAt time is zero, the data for the given session should be demoted back to unrepaired. Otherwise, it should be promoted to repaired with the given repaired time.
-
snapshot
void snapshot(java.lang.String name, java.util.Collection<Range<Token>> ranges, boolean force)
For snapshot repairs. A snapshot of the current data for the given ranges should be taken with the given name. If force is true, a snapshot should be taken even if one already exists with that name.
-
-