Uses of Interface
org.apache.cassandra.utils.concurrent.Future

Packages that use Future

Package	Description
org.apache.cassandra.batchlog
org.apache.cassandra.cache
org.apache.cassandra.concurrent
org.apache.cassandra.cql3
org.apache.cassandra.db
org.apache.cassandra.db.commitlog
org.apache.cassandra.db.compaction
org.apache.cassandra.db.memtable
org.apache.cassandra.db.repair
org.apache.cassandra.dht
org.apache.cassandra.hints	Hints subsystem consists of several components.
org.apache.cassandra.index
org.apache.cassandra.net
org.apache.cassandra.repair
org.apache.cassandra.repair.consistent
org.apache.cassandra.repair.messages
org.apache.cassandra.service
org.apache.cassandra.service.paxos.cleanup
org.apache.cassandra.service.reads.repair
org.apache.cassandra.streaming
org.apache.cassandra.streaming.async	Non-blocking streaming with netty
org.apache.cassandra.utils
org.apache.cassandra.utils.concurrent
org.apache.cassandra.utils.memory

Uses of Future in org.apache.cassandra.batchlog

Methods in org.apache.cassandra.batchlog that return Future

Modifier and Type	Method	Description
Future<?>	BatchlogManager.startBatchlogReplay()

Uses of Future in org.apache.cassandra.cache

Methods in org.apache.cassandra.cache that return Future

Modifier and Type	Method	Description
abstract Future<Pair<K,V>>	AutoSavingCache.CacheSerializer.deserialize(DataInputPlus in)
Future<Integer>	AutoSavingCache.loadSavedAsync()
Future<?>	AutoSavingCache.submitWrite(int keysToSave)

Uses of Future in org.apache.cassandra.concurrent

Classes in org.apache.cassandra.concurrent that implement Future

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>

Methods in org.apache.cassandra.concurrent that return Future

Modifier and Type	Method	Description
Future<?>	ExecutorPlus.submit(Runnable task)	Overrides ExecutorService.submit(Runnable) to return a Cassandra Future
<T> Future<T>	ExecutorPlus.submit(Runnable task, T result)	Overrides ExecutorService.submit(Runnable, Object) to return a Cassandra Future
<T> Future<T>	ExecutorPlus.submit(Callable<T> task)	Overrides ExecutorService.submit(Callable) to return a Cassandra Future
Future<?>	ExecutorPlus.submit(WithResources withResources, Runnable task)	Invoke task, returning a future yielding null if successful, or the abnormal termination of task otherwise.
<T> Future<T>	ExecutorPlus.submit(WithResources withResources, Runnable task, T result)	Invoke task, returning a future yielding result if successful, or the abnormal termination of task otherwise.
<T> Future<T>	ExecutorPlus.submit(WithResources withResources, Callable<T> task)	Invoke task, returning a future representing this computation.
Future<?>	ImmediateExecutor.submit(Runnable task)
<T> Future<T>	ImmediateExecutor.submit(Runnable task, T result)
<T> Future<T>	ImmediateExecutor.submit(Callable<T> task)
Future<?>	ImmediateExecutor.submit(WithResources withResources, Runnable task)
<T> Future<T>	ImmediateExecutor.submit(WithResources withResources, Runnable task, T result)
<T> Future<T>	ImmediateExecutor.submit(WithResources withResources, Callable<T> task)
Future<?>	ScheduledThreadPoolExecutorPlus.submit(Runnable run)
<T> Future<T>	ScheduledThreadPoolExecutorPlus.submit(Runnable run, T result)
<T> Future<T>	ScheduledThreadPoolExecutorPlus.submit(Callable<T> call)
Future<?>	ScheduledThreadPoolExecutorPlus.submit(WithResources withResources, Runnable run)
<T> Future<T>	ScheduledThreadPoolExecutorPlus.submit(WithResources withResources, Runnable run, T result)
<T> Future<T>	ScheduledThreadPoolExecutorPlus.submit(WithResources withResources, Callable<T> call)
Future<?>	SEPExecutor.submit(Runnable run)
<T> Future<T>	SEPExecutor.submit(Runnable run, T result)
<T> Future<T>	SEPExecutor.submit(Callable<T> call)
Future<?>	SEPExecutor.submit(WithResources withResources, Runnable run)
<T> Future<T>	SEPExecutor.submit(WithResources withResources, Runnable run, T result)
<T> Future<T>	SEPExecutor.submit(WithResources withResources, Callable<T> call)
Future<?>	Stage.submit(Runnable task)
<T> Future<T>	Stage.submit(Runnable task, T result)
<T> Future<T>	Stage.submit(Callable<T> task)
Future<?>	ThreadPoolExecutorPlus.submit(Runnable run)
<T> Future<T>	ThreadPoolExecutorPlus.submit(Runnable run, T result)
<T> Future<T>	ThreadPoolExecutorPlus.submit(Callable<T> call)
Future<?>	ThreadPoolExecutorPlus.submit(WithResources withResources, Runnable run)
<T> Future<T>	ThreadPoolExecutorPlus.submit(WithResources withResources, Runnable run, T result)
<T> Future<T>	ThreadPoolExecutorPlus.submit(WithResources withResources, Callable<T> call)
Future<?>	WrappedExecutorPlus.submit(Runnable task)
<T> Future<T>	WrappedExecutorPlus.submit(Runnable task, T result)
<T> Future<T>	WrappedExecutorPlus.submit(Callable<T> task)
Future<?>	WrappedExecutorPlus.submit(WithResources withResources, Runnable task)
<T> Future<T>	WrappedExecutorPlus.submit(WithResources withResources, Runnable task, T result)
<T> Future<T>	WrappedExecutorPlus.submit(WithResources withResources, Callable<T> task)

Uses of Future in org.apache.cassandra.cql3

Methods in org.apache.cassandra.cql3 that return Future

Modifier and Type	Method	Description
static Future<UntypedResultSet>	QueryProcessor.executeAsync(InetAddressAndPort address, String query, Object... values)

Uses of Future in org.apache.cassandra.db

Methods in org.apache.cassandra.db that return Future

Modifier and Type	Method	Description
Future<?>	Keyspace.applyFuture(Mutation mutation, boolean writeCommitLog, boolean updateIndexes)
Future<?>	Keyspace.applyFuture(Mutation mutation, boolean writeCommitLog, boolean updateIndexes, boolean isDroppable, boolean isDeferrable)
Future<?>	Mutation.applyFuture()
Future<CommitLogPosition>	ColumnFamilyStore.dumpMemtable()	Drops current memtable without flushing to disk.
Future<CommitLogPosition>	ColumnFamilyStore.forceFlush(ColumnFamilyStore.FlushReason reason)	Flush if there is unflushed data in the memtables
Future<?>	ColumnFamilyStore.forceFlush(CommitLogPosition flushIfDirtyBefore)	Flush if there is unflushed data that was written to the CommitLog before @param flushIfDirtyBefore (inclusive).
Future<CommitLogPosition>	ColumnFamilyStore.signalFlushRequired(Memtable memtable, ColumnFamilyStore.FlushReason reason)
Future<CommitLogPosition>	ColumnFamilyStore.switchMemtable(ColumnFamilyStore.FlushReason reason)
Future<CommitLogPosition>	ColumnFamilyStore.switchMemtableIfCurrent(Memtable memtable, ColumnFamilyStore.FlushReason reason)	Switches the memtable iff the live memtable is the one provided

Methods in org.apache.cassandra.db that return types with arguments of type Future

Modifier and Type	Method	Description
List<Future<?>>	Keyspace.flush(ColumnFamilyStore.FlushReason reason)

Uses of Future in org.apache.cassandra.db.commitlog

Methods in org.apache.cassandra.db.commitlog that return Future

Modifier and Type	Method	Description
protected Future<Integer>	CommitLogReplayer.MutationInitiator.initiateMutation(Mutation mutation, long segmentId, int serializedSize, int entryLocation, CommitLogReplayer commitLogReplayer)

Uses of Future in org.apache.cassandra.db.compaction

Methods in org.apache.cassandra.db.compaction that return Future

Modifier and Type	Method	Description
Future<?>	CompactionManager.submitCacheWrite(AutoSavingCache.Writer writer)
Future<?>	CompactionManager.submitIndexBuild(SecondaryIndexBuilder builder)	Is not scheduled, because it is performing disjoint work from sstable compaction.
Future<Void>	CompactionManager.submitPendingAntiCompaction(ColumnFamilyStore cfs, RangesAtEndpoint tokenRanges, Refs<SSTableReader> sstables, LifecycleTransaction txn, TimeUUID sessionId, BooleanSupplier isCancelled)	Splits the given token ranges of the given sstables into a pending repair silo
Future<?>	CompactionManager.submitUserDefined(ColumnFamilyStore cfs, Collection<Descriptor> dataFiles, long gcBefore)
Future<?>	CompactionManager.submitValidation(Callable<Object> validation)
Future<Long>	CompactionManager.submitViewBuilder(ViewBuilderTask task)

Methods in org.apache.cassandra.db.compaction that return types with arguments of type Future

Modifier and Type	Method	Description
List<Future<?>>	CompactionManager.submitBackground(ColumnFamilyStore cfs)	Call this whenever a compaction might be needed on the given columnfamily.
List<Future<?>>	CompactionManager.submitMaximal(ColumnFamilyStore cfStore, long gcBefore, boolean splitOutput)
List<Future<?>>	CompactionManager.submitMaximal(ColumnFamilyStore cfStore, long gcBefore, boolean splitOutput, OperationType operationType)

Uses of Future in org.apache.cassandra.db.memtable

Methods in org.apache.cassandra.db.memtable that return Future

Modifier and Type	Method	Description
static Future<Boolean>	AbstractAllocatorMemtable.flushLargestMemtable()	Finds the largest memtable, as a percentage of *either* on- or off-heap memory limits, and immediately queues it for flushing.
Future<CommitLogPosition>	Memtable.Owner.signalFlushRequired(Memtable memtable, ColumnFamilyStore.FlushReason reason)	Signal to the owner that a flush is required (e.g.

Uses of Future in org.apache.cassandra.db.repair

Methods in org.apache.cassandra.db.repair that return Future

Modifier and Type	Method	Description
Future<List<Void>>	CassandraKeyspaceRepairManager.prepareIncrementalRepair(TimeUUID sessionID, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)
Future<List<Void>>	PendingAntiCompaction.run()

Uses of Future in org.apache.cassandra.dht

Methods in org.apache.cassandra.dht that return Future

Modifier and Type	Method	Description
Future<StreamState>	BootStrapper.bootstrap(StreamStateStore stateStore, boolean useStrictConsistency)

Uses of Future in org.apache.cassandra.hints

Methods in org.apache.cassandra.hints that return Future

Modifier and Type	Method	Description
Future	HintsService.transferHints(Supplier<UUID> hostIdSupplier)	Transfer all local hints to the hostId supplied by hostIdSupplier Flushes the buffer to make sure all hints are on disk and closes the hint writers so we don't leave any hint files around.

Uses of Future in org.apache.cassandra.index

Methods in org.apache.cassandra.index that return Future

Modifier and Type	Method	Description
Future<?>	SecondaryIndexManager.addIndex(IndexMetadata indexDef, boolean isNewCF)	Adds and builds a index
Future<Void>	SecondaryIndexManager.buildIndex(Index index)

Uses of Future in org.apache.cassandra.net

Classes in org.apache.cassandra.net that implement Future

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.

Methods in org.apache.cassandra.net that return Future

Modifier and Type	Method	Description
<REQ, RSP> Future<Message<RSP>>	MessageDelivery.sendWithResult(Message<REQ> message, InetAddressAndPort to)
<REQ, RSP> Future<Message<RSP>>	MessagingService.sendWithResult(Message<REQ> message, InetAddressAndPort to)

Uses of Future in org.apache.cassandra.repair

Classes in org.apache.cassandra.repair that implement Future

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.

Methods in org.apache.cassandra.repair that return Future

Modifier and Type	Method	Description
default Future<CoordinatedRepairResult>	RepairTask.perform(ExecutorPlus executor, Scheduler validationScheduler)
Future<CoordinatedRepairResult>	IncrementalRepairTask.performUnsafe(ExecutorPlus executor, Scheduler validationScheduler)
Future<CoordinatedRepairResult>	NormalRepairTask.performUnsafe(ExecutorPlus executor, Scheduler validationScheduler)
Future<CoordinatedRepairResult>	PreviewRepairTask.performUnsafe(ExecutorPlus executor, Scheduler validationScheduler)
Future<CoordinatedRepairResult>	RepairTask.performUnsafe(ExecutorPlus executor, Scheduler validationScheduler)
Future<List<Void>>	KeyspaceRepairManager.prepareIncrementalRepair(TimeUUID sessionID, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)	Isolate the unrepaired ranges of the given tables, and make referenceable by session id.
protected Future<CoordinatedRepairResult>	AbstractRepairTask.runRepair(TimeUUID parentSession, boolean isIncremental, ExecutorPlus executor, Scheduler validationScheduler, List<CommonRange> commonRanges, String... cfnames)
default <T> Future<T>	Scheduler.schedule(Supplier<Future<T>> task, Executor executor)

Method parameters in org.apache.cassandra.repair with type arguments of type Future

Modifier and Type	Method	Description
default <T> Future<T>	Scheduler.schedule(Supplier<Future<T>> task, Executor executor)

Constructor parameters in org.apache.cassandra.repair with type arguments of type Future

Modifier	Constructor	Description
	Task(Supplier<Future<T>> supplier)

Uses of Future in org.apache.cassandra.repair.consistent

Methods in org.apache.cassandra.repair.consistent that return Future

Modifier and Type	Method	Description
Future<CoordinatedRepairResult>	CoordinatorSession.execute(Supplier<Future<CoordinatedRepairResult>> sessionSubmitter)	Runs the asynchronous consistent repair session.
Future<Void>	CoordinatorSession.finalizePropose()
Future<Void>	CoordinatorSession.prepare()

Method parameters in org.apache.cassandra.repair.consistent with type arguments of type Future

Modifier and Type	Method	Description
Future<CoordinatedRepairResult>	CoordinatorSession.execute(Supplier<Future<CoordinatedRepairResult>> sessionSubmitter)	Runs the asynchronous consistent repair session.

Uses of Future in org.apache.cassandra.repair.messages

Methods in org.apache.cassandra.repair.messages with parameters of type Future

Modifier and Type	Method	Description
static Supplier<Boolean>	RepairMessage.notDone(Future<?> f)

Uses of Future in org.apache.cassandra.service

Methods in org.apache.cassandra.service that return Future

Modifier and Type	Method	Description
Future<?>	StorageService.autoRepairPaxos(TableId tableId)
Future<Pair<CounterCacheKey,ClockAndCount>>	CacheService.CounterCacheSerializer.deserialize(DataInputPlus in)
Future<Pair<KeyCacheKey,AbstractRowIndexEntry>>	CacheService.KeyCacheSerializer.deserialize(DataInputPlus input)
Future<Pair<RowCacheKey,IRowCacheEntry>>	CacheService.RowCacheSerializer.deserialize(DataInputPlus in)
Future<?>	ActiveRepairService.prepareForRepair(TimeUUID parentRepairSession, InetAddressAndPort coordinator, Set<InetAddressAndPort> endpoints, RepairOption options, boolean isForcedRepair, List<ColumnFamilyStore> columnFamilyStores)
Future<?>	ActiveRepairService.repairPaxosForTopologyChange(String ksName, Collection<Range<Token>> ranges, String reason)
Future<StreamState>	StorageService.startBootstrap(Collection<Token> tokens)
Future<StreamState>	StorageService.startBootstrap(Collection<Token> tokens, boolean replacing)
Future<?>	StorageService.startRepairPaxosForTopologyChange(String reason)

Methods in org.apache.cassandra.service that return types with arguments of type Future

Modifier and Type	Method	Description
Supplier<Future<StreamState>>	StorageService.prepareUnbootstrapStreaming()
Pair<Integer,Future<?>>	StorageService.repair(String keyspace, Map<String,String> repairSpec, List<ProgressListener> listeners)
Pair<Integer,Future<?>>	StorageService.repair(String keyspace, RepairOption option, List<ProgressListener> listeners)

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

Classes in org.apache.cassandra.service.paxos.cleanup that implement Future

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 Future in org.apache.cassandra.service.reads.repair

Classes in org.apache.cassandra.service.reads.repair that implement Future

Modifier and Type	Class	Description
class	BlockingPartitionRepair

Uses of Future in org.apache.cassandra.streaming

Classes in org.apache.cassandra.streaming that implement Future

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

Uses of Future in org.apache.cassandra.streaming.async

Methods in org.apache.cassandra.streaming.async that return Future

Modifier and Type	Method	Description
Future<?>	NettyStreamingChannel.send(StreamingChannel.Send send)

Uses of Future in org.apache.cassandra.utils

Methods in org.apache.cassandra.utils that return Future

Modifier and Type	Method	Description
static <T> Future<List<T>>	FBUtilities.allOf(Collection<? extends Future<? extends T>> futures)	Returns a new Future wrapping the given list of futures and returning a list of their results.

Method parameters in org.apache.cassandra.utils with type arguments of type Future

Modifier and Type	Method	Description
static <T> Future<List<T>>	FBUtilities.allOf(Collection<? extends Future<? extends T>> futures)	Returns a new Future wrapping the given list of futures and returning a list of their results.

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

Subinterfaces of Future in org.apache.cassandra.utils.concurrent

Modifier and Type	Interface	Description
interface	Promise<V>	A Promise that integrates Promise with our Future API to improve clarity and coherence in the codebase.
interface	RunnableFuture<V>

Classes in org.apache.cassandra.utils.concurrent that implement Future

Modifier and Type	Class	Description
class	AbstractFuture<V>	Our default Future implementation, with all state being managed without locks (except those used by the JVM).
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 Future

Modifier and Type	Method	Description
Future<V>	AbstractFuture.addCallback(BiConsumer<? super V,Throwable> callback, Executor executor)
Future<V>	Future.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
Future<V>	Future.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
Future<V>	Future.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
Future<V>	Future.addCallback(BiConsumer<? super V,Throwable> 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
Future<V>	Future.addCallback(Consumer<? super V> onSuccess, Consumer<? super Throwable> onFailure)	Support Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>, java.util.concurrent.Executor) natively
Future<V>	Future.addCallback(Consumer<? super V> onSuccess, Consumer<? super Throwable> onFailure, 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
Future<V>	AbstractFuture.addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)	Add a listener to be invoked once this future completes.
Future<V>	Future.addListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> genericFutureListener)
Future<V>	AbstractFuture.addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... listeners)
Future<V>	Future.addListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... genericFutureListeners)
static <V> Future<List<V>>	FutureCombiner.allOf(Collection<? extends io.netty.util.concurrent.Future<? extends V>> futures)	Waits only until the first failure, or until all have succeeded.
Future<V>	Future.await()	Wait indefinitely for this future to complete, throwing any interrupt
Future<V>	SyncFuture.await()
Future<V>	AbstractFuture.awaitThrowUncheckedOnInterrupt()	Wait for this future to complete Awaitable.awaitThrowUncheckedOnInterrupt()
Future<V>	Future.awaitThrowUncheckedOnInterrupt()	Wait indefinitely for this promise to complete, throwing any interrupt as an UncheckedInterruptedException
Future<V>	AbstractFuture.awaitUninterruptibly()	Wait for this future to complete Awaitable.awaitUninterruptibly()
Future<V>	Future.awaitUninterruptibly()	Wait indefinitely for this future to complete
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 AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
<T> Future<T>	AsyncFuture.flatMap(Function<? super V,? extends Future<T>> flatMapper, Executor executor)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
default <T> Future<T>	Future.flatMap(Function<? super V,? extends Future<T>> flatMapper)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively
<T> Future<T>	Future.flatMap(Function<? super V,? extends Future<T>> flatMapper, Executor executor)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively
<T> Future<T>	SyncFuture.flatMap(Function<? super V,? extends Future<T>> flatMapper, Executor executor)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
<T> Future<T>	AbstractFuture.map(Function<? super V,? extends T> mapper)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively See AbstractFuture.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 AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
<T> Future<T>	AsyncFuture.map(Function<? super V,? extends T> mapper, Executor executor)	Support Futures.transform(com.google.common.util.concurrent.ListenableFuture<I>, com.google.common.base.Function<? super I, ? extends O>, java.util.concurrent.Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
default <T> Future<T>	Future.map(Function<? super V,? extends T> mapper)	Support Futures.transform(ListenableFuture, com.google.common.base.Function, Executor) natively
<T> Future<T>	Future.map(Function<? super V,? extends T> mapper, Executor executor)	Support Futures.transform(ListenableFuture, com.google.common.base.Function, Executor) natively
<T> Future<T>	SyncFuture.map(Function<? super V,? extends T> mapper, Executor executor)	Support Futures.transform(com.google.common.util.concurrent.ListenableFuture<I>, com.google.common.base.Function<? super I, ? extends O>, java.util.concurrent.Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
Future<V>	AbstractFuture.removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> listener)
Future<V>	Future.removeListener(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>> genericFutureListener)
Future<V>	AbstractFuture.removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... listeners)
Future<V>	Future.removeListeners(io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super V>>... genericFutureListeners)
static <V> Future<List<V>>	FutureCombiner.successfulOf(List<? extends io.netty.util.concurrent.Future<V>> futures)	Waits for all futures to complete, returning a list containing values of all successful input futures.
default Future<V>	Future.sync()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
default Future<V>	Future.syncThrowUncheckedOnInterrupt()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces
default Future<V>	Future.syncUninterruptibly()	waits for completion; in case of failure rethrows the original exception without a new wrapping exception so may cause problems for reporting stack traces

Methods in org.apache.cassandra.utils.concurrent that return types with arguments of type Future

Modifier and Type	Method	Description
static <V> io.netty.util.concurrent.GenericFutureListener<? extends Future<V>>	Promise.listener(com.google.common.util.concurrent.FutureCallback<V> callback)
static <V> io.netty.util.concurrent.GenericFutureListener<? extends Future<V>>	Promise.listener(ExecutorService executor, com.google.common.util.concurrent.FutureCallback<V> callback)

Method parameters in org.apache.cassandra.utils.concurrent with type arguments of type Future

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 AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
<T> Future<T>	AsyncFuture.flatMap(Function<? super V,? extends Future<T>> flatMapper, Executor executor)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.
default <T> Future<T>	Future.flatMap(Function<? super V,? extends Future<T>> flatMapper)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively
<T> Future<T>	Future.flatMap(Function<? super V,? extends Future<T>> flatMapper, Executor executor)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively
<T> Future<T>	SyncFuture.flatMap(Function<? super V,? extends Future<T>> flatMapper, Executor executor)	Support Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) natively See AbstractFuture.addListener(GenericFutureListener) for ordering semantics.

Uses of Future in org.apache.cassandra.utils.memory

Methods in org.apache.cassandra.utils.memory that return Future

Modifier and Type	Method	Description
Future<Boolean>	MemtableCleaner.clean()	This is a function that schedules a cleaning task, normally flushing of the largest sstable.