Package org.apache.cassandra.repair.autorepair

Class AutoRepairState

java.lang.Object
org.apache.cassandra.repair.autorepair.AutoRepairState
public abstract class AutoRepairState extends Object
AutoRepairState represents the state of automated repair for a given repair type.

  • Field Details

    • logger

      protected static final org.slf4j.Logger logger

    • timeFunc

      protected static Supplier<Long> timeFunc

    • repairType

      protected final AutoRepairConfig.RepairType repairType

    • config

      protected AutoRepairConfig config

    • totalTablesConsideredForRepair

      protected int totalTablesConsideredForRepair

    • lastRepairTimeInMs

      protected long lastRepairTimeInMs

    • nodeRepairTimeInSec

      protected int nodeRepairTimeInSec

    • clusterRepairTimeInSec

      protected int clusterRepairTimeInSec

    • repairInProgress

      protected boolean repairInProgress

    • repairKeyspaceCount

      protected int repairKeyspaceCount

    • totalMVTablesConsideredForRepair

      protected int totalMVTablesConsideredForRepair

    • totalDisabledTablesRepairCount

      protected int totalDisabledTablesRepairCount

    • failedTokenRangesCount

      protected int failedTokenRangesCount

    • succeededTokenRangesCount

      protected int succeededTokenRangesCount

    • skippedTokenRangesCount

      protected int skippedTokenRangesCount

    • skippedTablesCount

      protected int skippedTablesCount

    • totalBytesToRepair

      protected long totalBytesToRepair

    • bytesAlreadyRepaired

      protected long bytesAlreadyRepaired

    • totalKeyspaceRepairPlansToRepair

      protected int totalKeyspaceRepairPlansToRepair

    • keyspaceRepairPlansAlreadyRepaired

      protected int keyspaceRepairPlansAlreadyRepaired

    • longestUnrepairedNode

      protected AutoRepairUtils.AutoRepairHistory longestUnrepairedNode

    • metrics

      protected final AutoRepairMetrics metrics

  • Constructor Details

  • Method Details

    • getRepairRunnable

      public abstract RepairCoordinator getRepairRunnable(String keyspace, List<String> tables, Set<Range<Token>> ranges, boolean primaryRangeOnly)

    • getRepairRunnable

      protected RepairCoordinator getRepairRunnable(String keyspace, RepairOption options)

    • updateRepairScheduleStatistics

      public void updateRepairScheduleStatistics(List<PrioritizedRepairPlan> repairPlans)

    • getLastRepairTime

      public long getLastRepairTime()

    • setTotalTablesConsideredForRepair

      public void setTotalTablesConsideredForRepair(int count)

    • getTotalTablesConsideredForRepair

      public int getTotalTablesConsideredForRepair()

    • setLastRepairTime

      public void setLastRepairTime(long lastRepairTime)

    • getClusterRepairTimeInSec

      public int getClusterRepairTimeInSec()

    • getNodeRepairTimeInSec

      public int getNodeRepairTimeInSec()

    • setRepairInProgress

      public void setRepairInProgress(boolean repairInProgress)

    • isRepairInProgress

      public boolean isRepairInProgress()

    • getLongestUnrepairedSec

      public int getLongestUnrepairedSec()

    • setTotalMVTablesConsideredForRepair

      public void setTotalMVTablesConsideredForRepair(int count)

    • getTotalMVTablesConsideredForRepair

      public int getTotalMVTablesConsideredForRepair()

    • setNodeRepairTimeInSec

      public void setNodeRepairTimeInSec(int elapsed)

    • setClusterRepairTimeInSec

      public void setClusterRepairTimeInSec(int seconds)

    • setRepairKeyspaceCount

      public void setRepairKeyspaceCount(int count)

    • getRepairKeyspaceCount

      public int getRepairKeyspaceCount()

    • setLongestUnrepairedNode

      public void setLongestUnrepairedNode(AutoRepairUtils.AutoRepairHistory longestUnrepairedNode)

    • setFailedTokenRangesCount

      public void setFailedTokenRangesCount(int count)

    • getFailedTokenRangesCount

      public int getFailedTokenRangesCount()

    • setSucceededTokenRangesCount

      public void setSucceededTokenRangesCount(int count)

    • getSucceededTokenRangesCount

      public int getSucceededTokenRangesCount()

    • setSkippedTokenRangesCount

      public void setSkippedTokenRangesCount(int count)

    • getSkippedTokenRangesCount

      public int getSkippedTokenRangesCount()

    • setSkippedTablesCount

      public void setSkippedTablesCount(int count)

    • getSkippedTablesCount

      public int getSkippedTablesCount()

    • recordTurn

      public void recordTurn(AutoRepairUtils.RepairTurn turn)

    • setTotalDisabledTablesRepairCount

      public void setTotalDisabledTablesRepairCount(int count)

    • getTotalDisabledTablesRepairCount

      public int getTotalDisabledTablesRepairCount()

    • setTotalBytesToRepair

      public void setTotalBytesToRepair(long totalBytesToRepair)

    • getTotalBytesToRepair

      public long getTotalBytesToRepair()

    • setBytesAlreadyRepaired

      public void setBytesAlreadyRepaired(long bytesAlreadyRepaired)

    • getBytesAlreadyRepaired

      public long getBytesAlreadyRepaired()

    • setTotalKeyspaceRepairPlansToRepair

      public void setTotalKeyspaceRepairPlansToRepair(int totalKeyspaceRepairPlansToRepair)

    • getTotalKeyspaceRepairPlansToRepair

      public int getTotalKeyspaceRepairPlansToRepair()

    • setKeyspaceRepairPlansAlreadyRepaired

      public void setKeyspaceRepairPlansAlreadyRepaired(int keyspaceRepairPlansAlreadyRepaired)

    • getKeyspaceRepairPlansAlreadyRepaired

      public int getKeyspaceRepairPlansAlreadyRepaired()