Class PendingAntiCompaction


  • public class PendingAntiCompaction
    extends java.lang.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.
    • Constructor Detail

      • PendingAntiCompaction

        public PendingAntiCompaction​(java.util.UUID prsId,
                                     java.util.Collection<ColumnFamilyStore> tables,
                                     RangesAtEndpoint tokenRanges,
                                     java.util.concurrent.ExecutorService executor,
                                     java.util.function.BooleanSupplier isCancelled)
    • Method Detail

      • run

        public com.google.common.util.concurrent.ListenableFuture run()
      • getAcquisitionCallback

        protected org.apache.cassandra.db.repair.PendingAntiCompaction.AcquisitionCallback getAcquisitionCallback​(java.util.UUID prsId,
                                                                                                                  RangesAtEndpoint tokenRanges)