Package org.apache.cassandra.repair

Class AbstractRepairTask

java.lang.Object

org.apache.cassandra.repair.AbstractRepairTask

All Implemented Interfaces:

RepairTask

Direct Known Subclasses:

IncrementalRepairTask, NormalRepairTask, PreviewRepairTask

public abstract class AbstractRepairTask
extends java.lang.Object
implements RepairTask

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.String	keyspace
protected static org.slf4j.Logger	logger
protected RepairNotifier	notifier
protected RepairOption	options

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractRepairTask(RepairOption options, java.lang.String keyspace, RepairNotifier notifier)

Method Summary

Modifier and Type	Method	Description
protected Future<CoordinatedRepairResult>	runRepair(TimeUUID parentSession, boolean isIncremental, ExecutorPlus executor, Scheduler validationScheduler, java.util.List<CommonRange> commonRanges, java.lang.String... cfnames)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.repair.RepairTask

name, perform, performUnsafe, successMessage

Field Detail

logger

protected static final org.slf4j.Logger logger

options

protected final RepairOption options

keyspace

protected final java.lang.String keyspace

notifier

protected final RepairNotifier notifier

Constructor Detail

AbstractRepairTask

protected AbstractRepairTask(RepairOption options,
                             java.lang.String keyspace,
                             RepairNotifier notifier)

Method Detail

runRepair

protected Future<CoordinatedRepairResult> runRepair(TimeUUID parentSession,
                                                    boolean isIncremental,
                                                    ExecutorPlus executor,
                                                    Scheduler validationScheduler,
                                                    java.util.List<CommonRange> commonRanges,
                                                    java.lang.String... cfnames)