Uses of Class
org.apache.cassandra.utils.concurrent.AbstractFuture

Packages that use AbstractFuture

Package	Description
org.apache.cassandra.concurrent
org.apache.cassandra.net
org.apache.cassandra.repair
org.apache.cassandra.service.paxos.cleanup
org.apache.cassandra.service.reads.repair
org.apache.cassandra.streaming
org.apache.cassandra.utils.concurrent

Uses of AbstractFuture in org.apache.cassandra.concurrent

Subclasses of AbstractFuture in org.apache.cassandra.concurrent

Modifier and Type	Class	Description
class	FutureTask<V>	A FutureTask that utilises Cassandra's AsyncFuture, making it compatible with ExecutorPlus.
class	FutureTaskWithResources<V>	A FutureTask that utilises Cassandra's AsyncFuture, making it compatible with ExecutorPlus.
class	SyncFutureTask<T>

Uses of AbstractFuture in org.apache.cassandra.net

Subclasses of AbstractFuture in org.apache.cassandra.net

Modifier and Type	Class	Description
class	AsyncChannelPromise	See AsyncPromise and ChannelPromise This class is all boiler plate, just ensuring we return ourselves and invoke the correct Promise method.
class	AsyncOneResponse<T>	A callback specialized for returning a value from a single target; that is, this is for messages that we only send to one recipient.

Uses of AbstractFuture in org.apache.cassandra.repair

Subclasses of AbstractFuture in org.apache.cassandra.repair

Modifier and Type	Class	Description
class	AsymmetricRemoteSyncTask	AsymmetricRemoteSyncTask sends SyncRequest to target node to repair(stream) data with other target replica.
class	LocalSyncTask	LocalSyncTask performs streaming between local(coordinator) node and remote replica.
class	RepairJob	RepairJob runs repair on given ColumnFamily.
class	RepairSession	Coordinates the (active) repair of a list of non overlapping token ranges.
static class	Scheduler.Task<T>
class	SnapshotTask	SnapshotTask is a task that sends snapshot request.
class	SymmetricRemoteSyncTask	SymmetricRemoteSyncTask sends SyncRequest to remote(non-coordinator) node to repair(stream) data with other replica.
class	SyncTask
class	ValidationTask	ValidationTask sends ValidationRequest to a replica.

Uses of AbstractFuture in org.apache.cassandra.service.paxos.cleanup

Subclasses of AbstractFuture in org.apache.cassandra.service.paxos.cleanup

Modifier and Type	Class	Description
class	PaxosCleanup
class	PaxosCleanupComplete
class	PaxosCleanupLocalCoordinator
class	PaxosCleanupSession
class	PaxosFinishPrepareCleanup
class	PaxosStartPrepareCleanup	Determines the highest ballot we should attempt to repair

Uses of AbstractFuture in org.apache.cassandra.service.reads.repair

Subclasses of AbstractFuture in org.apache.cassandra.service.reads.repair

Modifier and Type	Class	Description
class	BlockingPartitionRepair

Uses of AbstractFuture in org.apache.cassandra.streaming

Subclasses of AbstractFuture in org.apache.cassandra.streaming

Modifier and Type	Class	Description
final class	StreamResultFuture	A future on the result (StreamState) of a streaming plan.

Uses of AbstractFuture in org.apache.cassandra.utils.concurrent

Subclasses of AbstractFuture in org.apache.cassandra.utils.concurrent

Modifier and Type	Class	Description
class	AsyncFuture<V>	Our default Future implementation, with all state being managed without locks (except those used by the JVM).
class	AsyncPromise<V>	Extends AsyncFuture to implement the Promise interface.
static class	AsyncPromise.WithExecutor<V>
class	FutureCombiner<T>	Netty's PromiseCombiner is not threadsafe, and we combine futures from multiple event executors.
class	ImmediateFuture<V>
class	SyncFuture<V>	Netty's DefaultPromise uses a mutex to coordinate notifiers AND waiters between the eventLoop and the other threads.
class	SyncPromise<V>	Extends SyncFuture to implement the Promise interface.
static class	SyncPromise.WithExecutor<V>

Methods in org.apache.cassandra.utils.concurrent that return AbstractFuture

Modifier and Type	Method	Description
AbstractFuture<V>	AbstractFuture.addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback)	Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively See addListener(GenericFutureListener) for ordering semantics.
AbstractFuture<V>	AbstractFuture.addCallback(com.google.common.util.concurrent.FutureCallback<? super V> callback, Executor executor)	Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively See addListener(GenericFutureListener) for ordering semantics.
AbstractFuture<V>	AbstractFuture.addCallback(BiConsumer<? super V,Throwable> callback)	Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively See addListener(GenericFutureListener) for ordering semantics.
AbstractFuture<V>	AbstractFuture.addCallback(Consumer<? super V> onSuccess, Consumer<? super Throwable> onFailure)	Support more fluid version of Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) See addListener(GenericFutureListener) for ordering semantics.
AbstractFuture<V>	AbstractFuture.addCallback(Consumer<? super V> onSuccess, Consumer<? super Throwable> onFailure, Executor executor)	Support more fluid version of Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) See addListener(GenericFutureListener) for ordering semantics.

Methods in org.apache.cassandra.utils.concurrent with parameters of type AbstractFuture

Modifier and Type	Method	Description
protected <T> Future<T>	AbstractFuture.flatMap(AbstractFuture<T> result, Function<? super V,? extends Future<T>> flatMapper, Executor executor)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively See addListener(GenericFutureListener) for ordering semantics.
protected <T> Future<T>	AbstractFuture.map(AbstractFuture<T> result, Function<? super V,? extends T> mapper, Executor executor)	Support Futures.transform(ListenableFuture, com.google.common.base.Function, Executor) natively See addListener(GenericFutureListener) for ordering semantics.