Class RepairJob

  • All Implemented Interfaces:
    com.google.common.util.concurrent.ListenableFuture<RepairResult>, java.lang.Runnable, java.util.concurrent.Future<RepairResult>

    public class RepairJob
    extends com.google.common.util.concurrent.AbstractFuture<RepairResult>
    implements java.lang.Runnable
    RepairJob runs repair on given ColumnFamily.
    • Constructor Summary

      Constructors 
      Constructor Description
      RepairJob​(RepairSession session, java.lang.String columnFamily)
      Create repair job to run on specific columnfamily
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int getNowInSeconds()  
      void run()
      Runs repair job.
      • Methods inherited from class com.google.common.util.concurrent.AbstractFuture

        addListener, afterDone, cancel, get, get, interruptTask, isCancelled, isDone, pendingToString, set, setException, setFuture, toString, tryInternalFastPathGetFailure, wasInterrupted
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • RepairJob

        public RepairJob​(RepairSession session,
                         java.lang.String columnFamily)
        Create repair job to run on specific columnfamily
        Parameters:
        session - RepairSession that this RepairJob belongs
        columnFamily - name of the ColumnFamily to repair
    • Method Detail

      • getNowInSeconds

        public int getNowInSeconds()
      • run

        public void run()
        Runs repair job. This sets up necessary task and runs them on given taskExecutor. After submitting all tasks, waits until validation with replica completes.
        Specified by:
        run in interface java.lang.Runnable