Package org.apache.cassandra.repair.autorepair

Class AutoRepairConfig

java.lang.Object

org.apache.cassandra.repair.autorepair.AutoRepairConfig

All Implemented Interfaces:

Serializable

public class AutoRepairConfig
extends Object
implements Serializable

Defines configurations for AutoRepair.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AutoRepairConfig.Options
static enum	AutoRepairConfig.RepairType

Field Summary

Fields

Modifier and Type	Field	Description
static final Class<? extends IAutoRepairTokenRangeSplitter>	DEFAULT_SPLITTER
Boolean	enabled
AutoRepairConfig.Options	global_settings
DurationSpec.IntSecondsBound	history_clear_delete_hosts_buffer_interval
boolean	mixed_major_version_repair_enabled
final DurationSpec.IntSecondsBound	repair_check_interval
DurationSpec.LongSecondsBound	repair_task_min_duration
ConcurrentMap<String,AutoRepairConfig.Options>	repair_type_overrides

Constructor Summary

Constructors

Constructor	Description
AutoRepairConfig()
AutoRepairConfig(boolean enabled)

Method Summary

Modifier and Type	Method	Description
protected <T> T	applyOverrides(AutoRepairConfig.RepairType repairType, Function<AutoRepairConfig.Options,T> optionSupplier)
boolean	getAllowParallelReplicaRepair(AutoRepairConfig.RepairType repairType)
boolean	getAllowParallelReplicaRepairAcrossSchedules(AutoRepairConfig.RepairType repairType)
DurationSpec.IntSecondsBound	getAutoRepairHistoryClearDeleteHostsBufferInterval()
DurationSpec.IntSecondsBound	getAutoRepairTableMaxRepairTime(AutoRepairConfig.RepairType repairType)
boolean	getForceRepairNewNode(AutoRepairConfig.RepairType repairType)
Set<String>	getIgnoreDCs(AutoRepairConfig.RepairType repairType)
DurationSpec.IntSecondsBound	getInitialSchedulerDelay(AutoRepairConfig.RepairType repairType)
boolean	getMaterializedViewRepairEnabled(AutoRepairConfig.RepairType repairType)
boolean	getMixedMajorVersionRepairEnabled()
protected AutoRepairConfig.Options	getOptions(AutoRepairConfig.RepairType repairType)
int	getParallelRepairCount(AutoRepairConfig.RepairType repairType)
int	getParallelRepairPercentage(AutoRepairConfig.RepairType repairType)
boolean	getRepairByKeyspace(AutoRepairConfig.RepairType repairType)
DurationSpec.IntSecondsBound	getRepairCheckInterval()
int	getRepairMaxRetries(AutoRepairConfig.RepairType repairType)
DurationSpec.IntSecondsBound	getRepairMinInterval(AutoRepairConfig.RepairType repairType)
boolean	getRepairPrimaryTokenRangeOnly(AutoRepairConfig.RepairType repairType)
DurationSpec.LongSecondsBound	getRepairRetryBackoff(AutoRepairConfig.RepairType repairType)
DurationSpec.IntSecondsBound	getRepairSessionTimeout(AutoRepairConfig.RepairType repairType)
int	getRepairSSTableCountHigherThreshold(AutoRepairConfig.RepairType repairType)
DurationSpec.LongSecondsBound	getRepairTaskMinDuration()
int	getRepairThreads(AutoRepairConfig.RepairType repairType)
ParameterizedClass	getTokenRangeSplitter(AutoRepairConfig.RepairType repairType)
IAutoRepairTokenRangeSplitter	getTokenRangeSplitterInstance(AutoRepairConfig.RepairType repairType)
boolean	isAutoRepairEnabled(AutoRepairConfig.RepairType repairType)
boolean	isAutoRepairSchedulingEnabled()
boolean	isMixedMajorVersionRepairEnabled()
void	setAllowParallelReplicaRepair(AutoRepairConfig.RepairType repairType, boolean enabled)
void	setAllowParallelReplicaRepairAcrossSchedules(AutoRepairConfig.RepairType repairType, boolean enabled)
void	setAutoRepairEnabled(AutoRepairConfig.RepairType repairType, boolean enabled)
void	setAutoRepairHistoryClearDeleteHostsBufferInterval(String duration)
void	setAutoRepairSchedulingEnabled(boolean enabled)
void	setAutoRepairTableMaxRepairTime(AutoRepairConfig.RepairType repairType, String autoRepairTableMaxRepairTime)
void	setForceRepairNewNode(AutoRepairConfig.RepairType repairType, boolean forceRepairNewNode)
void	setIgnoreDCs(AutoRepairConfig.RepairType repairType, Set<String> ignoreDCs)
void	setInitialSchedulerDelay(AutoRepairConfig.RepairType repairType, String initialSchedulerDelay)
void	setMaterializedViewRepairEnabled(AutoRepairConfig.RepairType repairType, boolean enabled)
void	setMixedMajorVersionRepairEnabled(boolean enabled)
void	setParallelRepairCount(AutoRepairConfig.RepairType repairType, int count)
void	setParallelRepairPercentage(AutoRepairConfig.RepairType repairType, int percentage)
void	setRepairByKeyspace(AutoRepairConfig.RepairType repairType, boolean repairByKeyspace)
void	setRepairMaxRetries(AutoRepairConfig.RepairType repairType, int maxRetries)
void	setRepairMinInterval(AutoRepairConfig.RepairType repairType, String minRepairInterval)
void	setRepairPrimaryTokenRangeOnly(AutoRepairConfig.RepairType repairType, boolean primaryTokenRangeOnly)
void	setRepairRetryBackoff(AutoRepairConfig.RepairType repairType, String interval)
void	setRepairSessionTimeout(AutoRepairConfig.RepairType repairType, String repairSessionTimeout)
void	setRepairSSTableCountHigherThreshold(AutoRepairConfig.RepairType repairType, int sstableHigherThreshold)
void	setRepairTaskMinDuration(String duration)
void	setRepairThreads(AutoRepairConfig.RepairType repairType, int repairThreads)
void	startScheduler()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

enabled

public volatile Boolean enabled

repair_check_interval

public final DurationSpec.IntSecondsBound repair_check_interval

history_clear_delete_hosts_buffer_interval

public volatile DurationSpec.IntSecondsBound history_clear_delete_hosts_buffer_interval

repair_task_min_duration

public volatile DurationSpec.LongSecondsBound repair_task_min_duration

mixed_major_version_repair_enabled

public volatile boolean mixed_major_version_repair_enabled

global_settings

public volatile AutoRepairConfig.Options global_settings

DEFAULT_SPLITTER

public static final Class<? extends IAutoRepairTokenRangeSplitter> DEFAULT_SPLITTER

repair_type_overrides

public volatile ConcurrentMap<String,AutoRepairConfig.Options> repair_type_overrides

Constructor Details

AutoRepairConfig

public AutoRepairConfig()

AutoRepairConfig

public AutoRepairConfig(boolean enabled)

Method Details

getRepairCheckInterval

public DurationSpec.IntSecondsBound getRepairCheckInterval()

isAutoRepairSchedulingEnabled

public boolean isAutoRepairSchedulingEnabled()

setAutoRepairSchedulingEnabled

public void setAutoRepairSchedulingEnabled(boolean enabled)

isMixedMajorVersionRepairEnabled

public boolean isMixedMajorVersionRepairEnabled()

getAutoRepairHistoryClearDeleteHostsBufferInterval

public DurationSpec.IntSecondsBound getAutoRepairHistoryClearDeleteHostsBufferInterval()

startScheduler

public void startScheduler()

setAutoRepairHistoryClearDeleteHostsBufferInterval

public void setAutoRepairHistoryClearDeleteHostsBufferInterval(String duration)

getRepairTaskMinDuration

public DurationSpec.LongSecondsBound getRepairTaskMinDuration()

setRepairTaskMinDuration

public void setRepairTaskMinDuration(String duration)

isAutoRepairEnabled

public boolean isAutoRepairEnabled(AutoRepairConfig.RepairType repairType)

setAutoRepairEnabled

public void setAutoRepairEnabled(AutoRepairConfig.RepairType repairType,
 boolean enabled)

setRepairByKeyspace

public void setRepairByKeyspace(AutoRepairConfig.RepairType repairType,
 boolean repairByKeyspace)

getRepairByKeyspace

public boolean getRepairByKeyspace(AutoRepairConfig.RepairType repairType)

getRepairThreads

public int getRepairThreads(AutoRepairConfig.RepairType repairType)

setRepairThreads

public void setRepairThreads(AutoRepairConfig.RepairType repairType,
 int repairThreads)

getRepairMinInterval

public DurationSpec.IntSecondsBound getRepairMinInterval(AutoRepairConfig.RepairType repairType)

setRepairMinInterval

public void setRepairMinInterval(AutoRepairConfig.RepairType repairType,
 String minRepairInterval)

getRepairSSTableCountHigherThreshold

public int getRepairSSTableCountHigherThreshold(AutoRepairConfig.RepairType repairType)

setRepairSSTableCountHigherThreshold

public void setRepairSSTableCountHigherThreshold(AutoRepairConfig.RepairType repairType,
 int sstableHigherThreshold)

getAutoRepairTableMaxRepairTime

public DurationSpec.IntSecondsBound getAutoRepairTableMaxRepairTime(AutoRepairConfig.RepairType repairType)

setAutoRepairTableMaxRepairTime

public void setAutoRepairTableMaxRepairTime(AutoRepairConfig.RepairType repairType,
 String autoRepairTableMaxRepairTime)

getIgnoreDCs

public Set<String> getIgnoreDCs(AutoRepairConfig.RepairType repairType)

setIgnoreDCs

public void setIgnoreDCs(AutoRepairConfig.RepairType repairType,
 Set<String> ignoreDCs)

getRepairPrimaryTokenRangeOnly

public boolean getRepairPrimaryTokenRangeOnly(AutoRepairConfig.RepairType repairType)

setRepairPrimaryTokenRangeOnly

public void setRepairPrimaryTokenRangeOnly(AutoRepairConfig.RepairType repairType,
 boolean primaryTokenRangeOnly)

getParallelRepairPercentage

public int getParallelRepairPercentage(AutoRepairConfig.RepairType repairType)

setParallelRepairPercentage

public void setParallelRepairPercentage(AutoRepairConfig.RepairType repairType,
 int percentage)

getParallelRepairCount

public int getParallelRepairCount(AutoRepairConfig.RepairType repairType)

setParallelRepairCount

public void setParallelRepairCount(AutoRepairConfig.RepairType repairType,
 int count)

getAllowParallelReplicaRepair

public boolean getAllowParallelReplicaRepair(AutoRepairConfig.RepairType repairType)

setAllowParallelReplicaRepair

public void setAllowParallelReplicaRepair(AutoRepairConfig.RepairType repairType,
 boolean enabled)

getAllowParallelReplicaRepairAcrossSchedules

public boolean getAllowParallelReplicaRepairAcrossSchedules(AutoRepairConfig.RepairType repairType)

setAllowParallelReplicaRepairAcrossSchedules

public void setAllowParallelReplicaRepairAcrossSchedules(AutoRepairConfig.RepairType repairType,
 boolean enabled)

getMaterializedViewRepairEnabled

public boolean getMaterializedViewRepairEnabled(AutoRepairConfig.RepairType repairType)

setMaterializedViewRepairEnabled

public void setMaterializedViewRepairEnabled(AutoRepairConfig.RepairType repairType,
 boolean enabled)

setForceRepairNewNode

public void setForceRepairNewNode(AutoRepairConfig.RepairType repairType,
 boolean forceRepairNewNode)

getForceRepairNewNode

public boolean getForceRepairNewNode(AutoRepairConfig.RepairType repairType)

getTokenRangeSplitter

public ParameterizedClass getTokenRangeSplitter(AutoRepairConfig.RepairType repairType)

getTokenRangeSplitterInstance

public IAutoRepairTokenRangeSplitter getTokenRangeSplitterInstance(AutoRepairConfig.RepairType repairType)

setInitialSchedulerDelay

public void setInitialSchedulerDelay(AutoRepairConfig.RepairType repairType,
 String initialSchedulerDelay)

getInitialSchedulerDelay

public DurationSpec.IntSecondsBound getInitialSchedulerDelay(AutoRepairConfig.RepairType repairType)

getRepairSessionTimeout

public DurationSpec.IntSecondsBound getRepairSessionTimeout(AutoRepairConfig.RepairType repairType)

setRepairSessionTimeout

public void setRepairSessionTimeout(AutoRepairConfig.RepairType repairType,
 String repairSessionTimeout)

getRepairMaxRetries

public int getRepairMaxRetries(AutoRepairConfig.RepairType repairType)

setRepairMaxRetries

public void setRepairMaxRetries(AutoRepairConfig.RepairType repairType,
 int maxRetries)

getRepairRetryBackoff

public DurationSpec.LongSecondsBound getRepairRetryBackoff(AutoRepairConfig.RepairType repairType)

setRepairRetryBackoff

public void setRepairRetryBackoff(AutoRepairConfig.RepairType repairType,
 String interval)

getMixedMajorVersionRepairEnabled

public boolean getMixedMajorVersionRepairEnabled()

setMixedMajorVersionRepairEnabled

public void setMixedMajorVersionRepairEnabled(boolean enabled)

getOptions

@Nonnull
protected AutoRepairConfig.Options getOptions(AutoRepairConfig.RepairType repairType)

applyOverrides

protected <T> T applyOverrides(AutoRepairConfig.RepairType repairType,
 Function<AutoRepairConfig.Options,T> optionSupplier)

toString

public String toString()

Overrides:

toString in class Object