Package org.apache.cassandra.repair.autorepair

Class AutoRepairUtils

java.lang.Object

org.apache.cassandra.repair.autorepair.AutoRepairUtils

public class AutoRepairUtils
extends Object

This class serves as a utility class for AutoRepair. It contains various helper APIs to store/retrieve repair status, decide whose turn is next, etc.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AutoRepairUtils.AutoRepairHistory
static class	AutoRepairUtils.CurrentRepairStatus
static enum	AutoRepairUtils.RepairTurn
protected static class	AutoRepairUtils.SizeEstimate	Represents a size estimate by both bytes and partition count for a given keyspace and table for a token range.

Constructor Summary

Constructors

Constructor	Description
AutoRepairUtils()

Method Summary

Modifier and Type	Method	Description
static void	addHostIdToDeleteHosts(AutoRepairConfig.RepairType repairType, UUID myID, UUID hostToBeDeleted)
static void	addPriorityHosts(AutoRepairConfig.RepairType repairType, Set<InetAddressAndPort> hosts)
static Map<String,Map<Range<Token>,AutoRepairUtils.SizeEstimate>>	calcTotalBytesToBeRepaired(AutoRepairConfig.RepairType repairType, String keyspaceName, List<String> tableNames, List<Range<Token>> tokenRanges)	Calculates the total bytes to be repaired for a given keyspace and list of tables.
static void	clearDeleteHosts(AutoRepairConfig.RepairType repairType, UUID hostId)
static List<String>	getAllMVs(AutoRepairConfig.RepairType repairType, Keyspace keyspace, TableMetadata tableMetadata)
static List<AutoRepairUtils.AutoRepairHistory>	getAutoRepairHistory(AutoRepairConfig.RepairType repairType)
static AutoRepairUtils.CurrentRepairStatus	getCurrentRepairStatus(AutoRepairConfig.RepairType repairType, List<AutoRepairUtils.AutoRepairHistory> autoRepairHistories, UUID myId)
static TreeSet<UUID>	getHostIdsInCurrentRing(AutoRepairConfig.RepairType repairType)
protected static TreeSet<UUID>	getHostIdsInCurrentRing(AutoRepairConfig.RepairType repairType, Set<InetAddressAndPort> allNodesInRing)
static AutoRepairUtils.AutoRepairHistory	getHostWithLongestUnrepairTime(AutoRepairConfig.RepairType repairType)
static String	getKeyspaceTableName(String keyspace, String table)
static long	getLastRepairTimeForNode(AutoRepairConfig.RepairType repairType, UUID hostId)
static int	getMaxNumberOfNodeRunAutoRepair(AutoRepairConfig.RepairType repairType, int groupSize)
static AutoRepairUtils.AutoRepairHistory	getMostEligibleHostToRepair(AutoRepairConfig.RepairType repairType, AutoRepairUtils.CurrentRepairStatus currentRepairStatus, UUID myId)	Identifies the most eligible host to repair for nodes preceding or equal to this nodes' lastRepairFinishTime.
static Set<UUID>	getPriorityHostIds(AutoRepairConfig.RepairType repairType)
static Set<InetAddressAndPort>	getPriorityHosts(AutoRepairConfig.RepairType repairType)
static List<Range<Token>>	getTokenRanges(boolean primaryRangeOnly, String keyspaceName)	Calculates the token ranges owned by this node for a given keyspace.
static boolean	hasMultipleLiveMajorVersions()	Checks whether the cluster has multiple major versions
static boolean	hasNodesBelowMinimumVersion()	Checks whether any node in the cluster is running an unsupported version for auto-repair.
static void	insertNewRepairHistory(AutoRepairConfig.RepairType repairType, long startTime, long finishTime)
static void	insertNewRepairHistory(AutoRepairConfig.RepairType repairType, UUID hostId, long startTime, long finishTime)
static boolean	keyspaceMaxRepairTimeExceeded(AutoRepairConfig.RepairType repairType, long startTime, int numOfTablesToBeRepaired)
static AutoRepairUtils.RepairTurn	myTurnToRunRepair(AutoRepairConfig.RepairType repairType, UUID myId)
static void	setForceRepair(AutoRepairConfig.RepairType repairType, Set<InetAddressAndPort> hosts)
static void	setForceRepair(AutoRepairConfig.RepairType repairType, UUID hostId)
static void	setForceRepairNewNode(AutoRepairConfig.RepairType repairType)
static void	setup()
static boolean	shouldConsiderKeyspace(Keyspace ks)
static Collection<Range<Token>>	split(Range<Token> tokenRange, int numberOfSplits)
static boolean	tableMaxRepairTimeExceeded(AutoRepairConfig.RepairType repairType, long startTime)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AutoRepairUtils

public AutoRepairUtils()

Method Details

setup

public static void setup()

getAutoRepairHistory

public static List<AutoRepairUtils.AutoRepairHistory> getAutoRepairHistory(AutoRepairConfig.RepairType repairType)

clearDeleteHosts

public static void clearDeleteHosts(AutoRepairConfig.RepairType repairType,
 UUID hostId)

setForceRepairNewNode

public static void setForceRepairNewNode(AutoRepairConfig.RepairType repairType)

setForceRepair

public static void setForceRepair(AutoRepairConfig.RepairType repairType,
 Set<InetAddressAndPort> hosts)

setForceRepair

public static void setForceRepair(AutoRepairConfig.RepairType repairType,
 UUID hostId)

getLastRepairTimeForNode

public static long getLastRepairTimeForNode(AutoRepairConfig.RepairType repairType,
 UUID hostId)

getCurrentRepairStatus

public static AutoRepairUtils.CurrentRepairStatus getCurrentRepairStatus(AutoRepairConfig.RepairType repairType,
 List<AutoRepairUtils.AutoRepairHistory> autoRepairHistories,
 UUID myId)

hasMultipleLiveMajorVersions

public static boolean hasMultipleLiveMajorVersions()

Checks whether the cluster has multiple major versions

Returns:

true if more than one major versions are detected false if only one major version is detected

hasNodesBelowMinimumVersion

public static boolean hasNodesBelowMinimumVersion()

Checks whether any node in the cluster is running an unsupported version for auto-repair.

Returns:

true if any live node has a version at or below 5.0.7 (unsupported) or has an unknown version, false if all nodes are running versions above 5.0.7 (supported)

getHostIdsInCurrentRing

protected static TreeSet<UUID> getHostIdsInCurrentRing(AutoRepairConfig.RepairType repairType,
 Set<InetAddressAndPort> allNodesInRing)

getHostIdsInCurrentRing

public static TreeSet<UUID> getHostIdsInCurrentRing(AutoRepairConfig.RepairType repairType)

getHostWithLongestUnrepairTime

public static AutoRepairUtils.AutoRepairHistory getHostWithLongestUnrepairTime(AutoRepairConfig.RepairType repairType)

getMostEligibleHostToRepair

public static AutoRepairUtils.AutoRepairHistory getMostEligibleHostToRepair(AutoRepairConfig.RepairType repairType,
 AutoRepairUtils.CurrentRepairStatus currentRepairStatus,
 UUID myId)

Identifies the most eligible host to repair for nodes preceding or equal to this nodes' lastRepairFinishTime. The criteria for this is to find the node with the oldest last repair finish time of which none of its replicas are currently under repair.

Returns:

The most eligible host to repair or null if no candidates before and including this nodes' current repair status.

getMaxNumberOfNodeRunAutoRepair

public static int getMaxNumberOfNodeRunAutoRepair(AutoRepairConfig.RepairType repairType,
 int groupSize)

myTurnToRunRepair

public static AutoRepairUtils.RepairTurn myTurnToRunRepair(AutoRepairConfig.RepairType repairType,
 UUID myId)

insertNewRepairHistory

public static void insertNewRepairHistory(AutoRepairConfig.RepairType repairType,
 UUID hostId,
 long startTime,
 long finishTime)

insertNewRepairHistory

public static void insertNewRepairHistory(AutoRepairConfig.RepairType repairType,
 long startTime,
 long finishTime)

addHostIdToDeleteHosts

public static void addHostIdToDeleteHosts(AutoRepairConfig.RepairType repairType,
 UUID myID,
 UUID hostToBeDeleted)

addPriorityHosts

public static void addPriorityHosts(AutoRepairConfig.RepairType repairType,
 Set<InetAddressAndPort> hosts)

getPriorityHostIds

public static Set<UUID> getPriorityHostIds(AutoRepairConfig.RepairType repairType)

getPriorityHosts

public static Set<InetAddressAndPort> getPriorityHosts(AutoRepairConfig.RepairType repairType)

shouldConsiderKeyspace

public static boolean shouldConsiderKeyspace(Keyspace ks)

tableMaxRepairTimeExceeded

public static boolean tableMaxRepairTimeExceeded(AutoRepairConfig.RepairType repairType,
 long startTime)

keyspaceMaxRepairTimeExceeded

public static boolean keyspaceMaxRepairTimeExceeded(AutoRepairConfig.RepairType repairType,
 long startTime,
 int numOfTablesToBeRepaired)

getAllMVs

public static List<String> getAllMVs(AutoRepairConfig.RepairType repairType,
 Keyspace keyspace,
 TableMetadata tableMetadata)

split

public static Collection<Range<Token>> split(Range<Token> tokenRange,
 int numberOfSplits)

getTokenRanges

public static List<Range<Token>> getTokenRanges(boolean primaryRangeOnly,
 String keyspaceName)

Calculates the token ranges owned by this node for a given keyspace.

Parameters:

primaryRangeOnly - whether to use only primary token ranges or include replicated ones

keyspaceName - the name of the keyspace

Returns:

one or more token ranges owned by this node

calcTotalBytesToBeRepaired

public static Map<String,Map<Range<Token>,AutoRepairUtils.SizeEstimate>> calcTotalBytesToBeRepaired(AutoRepairConfig.RepairType repairType,
 String keyspaceName,
 List<String> tableNames,
 List<Range<Token>> tokenRanges)

Calculates the total bytes to be repaired for a given keyspace and list of tables.

Parameters:

repairType - the repair type (e.g., FULL, INCREMENTAL)

keyspaceName - the name of the keyspace

tableNames - the list of tables

Returns:

a key-value map where the key is keyspaceName.tableName and the value is the number of bytes to be repaired.

getKeyspaceTableName

public static String getKeyspaceTableName(String keyspace,
 String table)