Package org.apache.cassandra.service.paxos.cleanup

Class PaxosCleanupLocalCoordinator

java.lang.Object

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

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

org.apache.cassandra.service.paxos.cleanup.PaxosCleanupLocalCoordinator

All Implemented Interfaces:

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

public class PaxosCleanupLocalCoordinator
extends AsyncFuture<PaxosCleanupResponse>

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 inherited from class org.apache.cassandra.utils.concurrent.AbstractFuture

CANCELLED, UNCANCELLABLE, UNSET

Method Summary

Modifier and Type	Method	Description
static PaxosCleanupLocalCoordinator	create(SharedContext ctx, PaxosCleanupRequest request)
static PaxosCleanupLocalCoordinator	createForAutoRepair(SharedContext ctx, TableId tableId, Collection<Range<Token>> ranges)
void	start()

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

Method Details

start

public void start()

create

public static PaxosCleanupLocalCoordinator create(SharedContext ctx,
 PaxosCleanupRequest request)

createForAutoRepair

public static PaxosCleanupLocalCoordinator createForAutoRepair(SharedContext ctx,
 TableId tableId,
 Collection<Range<Token>> ranges)