Package org.apache.cassandra.repair

Class RepairJob

java.lang.Object

org.apache.cassandra.utils.concurrent.AbstractFuture<V>

org.apache.cassandra.utils.concurrent.AsyncFuture<RepairResult>

org.apache.cassandra.repair.RepairJob

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<RepairResult>, io.netty.util.concurrent.Future<RepairResult>, Runnable, Future<RepairResult>, Awaitable, Future<RepairResult>

public class RepairJob
extends AsyncFuture<RepairResult>
implements Runnable

RepairJob runs repair on given ColumnFamily.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Awaitable

Awaitable.AbstractAwaitable, Awaitable.AsyncAwaitable, Awaitable.Defaults, Awaitable.SyncAwaitable

Field Summary

Fields

Modifier and Type	Field	Description
final JobState	state

Fields inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

CANCELLED, UNCANCELLABLE, UNSET

Constructor Summary

Constructors

Constructor	Description
RepairJob(RepairSession session, String columnFamily)	Create repair job to run on specific columnfamily

Method Summary

Modifier and Type	Method	Description
void	abort(Throwable reason)
long	getNowInSeconds()
void	run()	Runs repair job.

Methods inherited from class org.apache.cassandra.utils.concurrent.AsyncFuture

await, awaitUntil, flatMap, map

Methods inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

addCallback, addCallback, addCallback, addCallback, addCallback, addCallback, addListener, addListener, addListener, addListeners, await, awaitThrowUncheckedOnInterrupt, awaitThrowUncheckedOnInterrupt, awaitUninterruptibly, awaitUninterruptibly, awaitUntilThrowUncheckedOnInterrupt, awaitUntilUninterruptibly, cancel, cause, description, flatMap, get, get, getNow, getWhenDone, isCancellable, isCancelled, isDone, isSuccess, isUncancellable, map, map, notifyExecutor, removeListener, removeListeners, setUncancellable, setUncancellableExclusive, toString, tryFailure, trySuccess

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.utils.concurrent.Future

await, awaitUninterruptibly, flatMap, rethrowIfFailed, sync, syncThrowUncheckedOnInterrupt, syncUninterruptibly

Field Details

state

public final JobState state

Constructor Details

RepairJob

public RepairJob(RepairSession session,
 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 Details

getNowInSeconds

public long 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 Runnable

abort

public void abort(@Nullable
 Throwable reason)