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

Class PaxosCleanup

java.lang.Object

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

org.apache.cassandra.utils.concurrent.AsyncFuture<java.lang.Void>

org.apache.cassandra.service.paxos.cleanup.PaxosCleanup

All Implemented Interfaces:

com.google.common.util.concurrent.ListenableFuture<java.lang.Void>, io.netty.util.concurrent.Future<java.lang.Void>, java.lang.Runnable, java.util.concurrent.Future<java.lang.Void>, Awaitable, Future<java.lang.Void>

public class PaxosCleanup
extends AsyncFuture<java.lang.Void>
implements java.lang.Runnable

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

Constructor Summary

Constructors

Constructor	Description
PaxosCleanup(java.util.Collection<InetAddressAndPort> endpoints, TableMetadata table, java.util.Collection<Range<Token>> ranges, boolean skippedReplicas, java.util.concurrent.Executor executor)

Method Summary

Modifier and Type	Method	Description
static PaxosCleanup	cleanup(java.util.Collection<InetAddressAndPort> endpoints, TableMetadata table, java.util.Collection<Range<Token>> ranges, boolean skippedReplicas, java.util.concurrent.Executor executor)
void	run()

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

Constructor Detail

PaxosCleanup

public PaxosCleanup(java.util.Collection<InetAddressAndPort> endpoints,
                    TableMetadata table,
                    java.util.Collection<Range<Token>> ranges,
                    boolean skippedReplicas,
                    java.util.concurrent.Executor executor)

Method Detail

cleanup

public static PaxosCleanup cleanup(java.util.Collection<InetAddressAndPort> endpoints,
                                   TableMetadata table,
                                   java.util.Collection<Range<Token>> ranges,
                                   boolean skippedReplicas,
                                   java.util.concurrent.Executor executor)

run

public void run()

Specified by:

run in interface java.lang.Runnable