Uses of Interface
com.hazelcast.core.ICompletableFuture

Packages that use ICompletableFuture

Package	Description
com.hazelcast.cache	This package contains the public API extension for Hazelcast JCache, the Hazelcast implementation of the JSR-107 commonly referred to as JCache.
com.hazelcast.client.proxy	This package contains client side proxy implementations of the different Hazelcast data structures and operation types
com.hazelcast.client.spi	Contains classes/interfaces related to Service Provider Interface such as ClientProxy , ClientClusterService
com.hazelcast.client.spi.impl	Provides util classes for com.hazelcast.client
com.hazelcast.client.util	This package contains some utility classes and the base implementations of the loadbalancer implementations
com.hazelcast.core	Provides core API interfaces/classes.
com.hazelcast.durableexecutor	This package contains DurableExecutorService functionality for Hazelcast. The DurableExecutorService extends the ExecutorService and provides additional methods like executing tasks on a member who is owner of a specific key.
com.hazelcast.map.impl.proxy	Contains map proxy implementation and support classes.
com.hazelcast.mapreduce	This package contains the MapReduce API definition for Hazelcast. All map reduce operations running in a distributed manner inside the active Hazelcast cluster.
com.hazelcast.mapreduce.impl.task	This package contains the base implementation for a standard map reduce job.
com.hazelcast.ringbuffer	Contains the API for the Ringbuffer.
com.hazelcast.ringbuffer.impl	Contains the Ringbuffer implementation classes.
com.hazelcast.spi	Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services.
com.hazelcast.spi.impl	Contains implementations for Hazelcast SPI.
com.hazelcast.spi.impl.executionservice.impl	Contains the implementation of the InternalExecutionService.
com.hazelcast.util.executor	This package contains classes related to Util.Executor

Uses of ICompletableFuture in com.hazelcast.cache

Methods in com.hazelcast.cache that return ICompletableFuture

Modifier and Type	Method and Description
ICompletableFuture<V>	ICache.getAndPutAsync(K key, V value) Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed.
ICompletableFuture<V>	ICache.getAndPutAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy) Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed using a custom ExpiryPolicy.
ICompletableFuture<V>	ICache.getAndRemoveAsync(K key) Asynchronously removes the entry for a key and returns the previously assigned value or null if no value was assigned.
ICompletableFuture<V>	ICache.getAndReplaceAsync(K key, V value) Asynchronously replaces the assigned value of the given key by the specified value and returns the previously assigned value.
ICompletableFuture<V>	ICache.getAndReplaceAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy) Asynchronously replaces the assigned value of the given key by the specified value using a custom ExpiryPolicy and returns the previously assigned value.
ICompletableFuture<V>	ICache.getAsync(K key) Asynchronously retrieves the mapped value of the given key using a custom ExpiryPolicy.
ICompletableFuture<V>	ICache.getAsync(K key, javax.cache.expiry.ExpiryPolicy expiryPolicy) Asynchronously gets an entry from cache using a custom ExpiryPolicy.
ICompletableFuture<Void>	ICache.putAsync(K key, V value) Asynchronously associates the specified value with the specified key in the cache.
ICompletableFuture<Void>	ICache.putAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy) Asynchronously associates the specified value with the specified key in the cache using a custom ExpiryPolicy.
ICompletableFuture<Boolean>	ICache.putIfAbsentAsync(K key, V value) Asynchronously associates the specified key with the given value if and only if there is not yet a mapping defined for the specified key.
ICompletableFuture<Boolean>	ICache.putIfAbsentAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy) Asynchronously associates the specified key with the given value if and only if there is not yet a mapping defined for the specified key.
ICompletableFuture<Boolean>	ICache.removeAsync(K key) Asynchronously removes the mapping for a key from this cache if it is present.
ICompletableFuture<Boolean>	ICache.removeAsync(K key, V oldValue) Asynchronously removes the mapping for the given key if and only if the currently mapped value equals to the value of oldValue.
ICompletableFuture<Boolean>	ICache.replaceAsync(K key, V value) Asynchronously replaces the assigned value of the given key by the specified value.
ICompletableFuture<Boolean>	ICache.replaceAsync(K key, V value, javax.cache.expiry.ExpiryPolicy expiryPolicy) Asynchronously replaces the assigned value of the given key by the specified value using a custom ExpiryPolicy.
ICompletableFuture<Boolean>	ICache.replaceAsync(K key, V oldValue, V newValue) Asynchronously replaces the currently assigned value for the given key with the specified newValue if and only if the currently assigned value equals the value of oldValue.
ICompletableFuture<Boolean>	ICache.replaceAsync(K key, V oldValue, V newValue, javax.cache.expiry.ExpiryPolicy expiryPolicy) Asynchronously replaces the currently assigned value for the given key with the specified newValue if and only if the currently assigned value equals the value of oldValue using a custom ExpiryPolicy.

Uses of ICompletableFuture in com.hazelcast.client.proxy

Methods in com.hazelcast.client.proxy that return ICompletableFuture

Modifier and Type	Method and Description
ICompletableFuture<Long>	ClientRingbufferProxy.addAllAsync(Collection<? extends E> collection, OverflowPolicy overflowPolicy)
ICompletableFuture<Long>	ClientRingbufferProxy.addAsync(E item, OverflowPolicy overflowPolicy)
ICompletableFuture<V>	ClientMapProxy.getAsync(K key)
ICompletableFuture<V>	NearCachedClientMapProxy.getAsyncInternal(Data keyData)
protected ICompletableFuture<V>	ClientMapProxy.getAsyncInternal(Data keyData)
ICompletableFuture<V>	ClientMapProxy.putAsync(K key, V value)
ICompletableFuture<V>	ClientMapProxy.putAsync(K key, V value, long ttl, TimeUnit timeunit)
protected ICompletableFuture<V>	NearCachedClientMapProxy.putAsyncInternal(long ttl, TimeUnit timeunit, Data keyData, Data valueData)
protected ICompletableFuture<V>	ClientMapProxy.putAsyncInternal(long ttl, TimeUnit timeunit, Data keyData, Data valueData)
ICompletableFuture<ReadResultSet<E>>	ClientRingbufferProxy.readManyAsync(long startSequence, int minCount, int maxCount, IFunction<E,Boolean> filter)
ICompletableFuture<V>	ClientMapProxy.removeAsync(K key)
protected ICompletableFuture<V>	NearCachedClientMapProxy.removeAsyncInternal(Data keyData)
protected ICompletableFuture<V>	ClientMapProxy.removeAsyncInternal(Data keyData)
ICompletableFuture<Void>	ClientMapProxy.setAsync(K key, V value)
ICompletableFuture<Void>	ClientMapProxy.setAsync(K key, V value, long ttl, TimeUnit timeunit)
protected ICompletableFuture<Void>	NearCachedClientMapProxy.setAsyncInternal(long ttl, TimeUnit timeunit, Data keyData, Data valueData)
protected ICompletableFuture<Void>	ClientMapProxy.setAsyncInternal(long ttl, TimeUnit timeunit, Data keyData, Data valueData)
ICompletableFuture	ClientMapProxy.submitToKey(K key, EntryProcessor entryProcessor)
ICompletableFuture	NearCachedClientMapProxy.submitToKeyInternal(Data keyData, EntryProcessor entryProcessor)
ICompletableFuture	ClientMapProxy.submitToKeyInternal(Data keyData, EntryProcessor entryProcessor)

Uses of ICompletableFuture in com.hazelcast.client.spi

Methods in com.hazelcast.client.spi that return ICompletableFuture

Modifier and Type	Method and Description
<T> ICompletableFuture<T>	ClientExecutionService.submit(Callable<T> task)
ICompletableFuture<?>	ClientExecutionService.submit(Runnable task)

Uses of ICompletableFuture in com.hazelcast.client.spi.impl

Classes in com.hazelcast.client.spi.impl that implement ICompletableFuture

Modifier and Type	Class and Description
class	ClientInvocationFuture

Methods in com.hazelcast.client.spi.impl that return ICompletableFuture

Modifier and Type	Method and Description
<T> ICompletableFuture<T>	ClientExecutionServiceImpl.submit(Callable<T> task)
ICompletableFuture<?>	ClientExecutionServiceImpl.submit(Runnable task)
<T> ICompletableFuture<T>	ClientExecutionServiceImpl.submitInternal(Runnable runnable)

Uses of ICompletableFuture in com.hazelcast.client.util

Classes in com.hazelcast.client.util that implement ICompletableFuture

Modifier and Type	Class and Description
class	ClientAddressCancellableDelegatingFuture<V> A DelegatingFuture that can cancel a Runnable/Callable that is executed by an IExecutorService.
class	ClientCancellableDelegatingFuture<V> An Abstract DelegatingFuture that can cancel a Runnable/Callable that is executed by an IExecutorService.
class	ClientDelegatingFuture<V> Client Delegating Future is used to delegate ClientInvocationFuture to user to be used with andThen or get.
class	ClientPartitionCancellableDelegatingFuture<T> A DelegatingFuture that can cancel a Runnable/Callable that is executed by an IExecutorService.

Uses of ICompletableFuture in com.hazelcast.core

Methods in com.hazelcast.core that return ICompletableFuture

Modifier and Type	Method and Description
ICompletableFuture<Long>	IAtomicLong.addAndGetAsync(long delta) Atomically adds the given value to the current value.
ICompletableFuture<E>	IAtomicReference.alterAndGetAsync(IFunction<E,E> function) Alters the currently stored reference by applying a function on it and gets the result.
ICompletableFuture<Long>	IAtomicLong.alterAndGetAsync(IFunction<Long,Long> function) Alters the currently stored value by applying a function on it and gets the result.
ICompletableFuture<Void>	IAtomicReference.alterAsync(IFunction<E,E> function) Alters the currently stored reference by applying a function on it.
ICompletableFuture<Void>	IAtomicLong.alterAsync(IFunction<Long,Long> function) Alters the currently stored value by applying a function on it.
<R> ICompletableFuture<R>	IAtomicReference.applyAsync(IFunction<E,R> function) Applies a function on the value, the actual stored value will not change.
<R> ICompletableFuture<R>	IAtomicLong.applyAsync(IFunction<Long,R> function) Applies a function on the value, the actual stored value will not change.
ICompletableFuture<Long>	AsyncAtomicLong.asyncAddAndGet(long delta) Deprecated. Atomically adds the given value to the current value.
ICompletableFuture<Void>	AsyncAtomicReference.asyncAlter(IFunction<E,E> function) Deprecated. Alters the currently stored reference by applying a function on it.
ICompletableFuture<Void>	AsyncAtomicLong.asyncAlter(IFunction<Long,Long> function) Deprecated. Alters the currently stored value by applying a function on it.
ICompletableFuture<E>	AsyncAtomicReference.asyncAlterAndGet(IFunction<E,E> function) Deprecated. Alters the currently stored reference by applying a function on it and gets the result.
ICompletableFuture<Long>	AsyncAtomicLong.asyncAlterAndGet(IFunction<Long,Long> function) Deprecated. Alters the currently stored value by applying a function on it and gets the result.
<R> ICompletableFuture<R>	AsyncAtomicReference.asyncApply(IFunction<E,R> function) Deprecated. Applies a function on the value, the actual stored value will not change.
<R> ICompletableFuture<R>	AsyncAtomicLong.asyncApply(IFunction<Long,R> function) Deprecated. Applies a function on the value, the actual stored value will not change.
ICompletableFuture<Void>	AsyncAtomicReference.asyncClear() Deprecated. Clears the current stored reference.
ICompletableFuture<Boolean>	AsyncAtomicReference.asyncCompareAndSet(E expect, E update) Deprecated. Atomically sets the value to the given updated value only if the current value == the expected value.
ICompletableFuture<Boolean>	AsyncAtomicLong.asyncCompareAndSet(long expect, long update) Deprecated. Atomically sets the value to the given updated value only if the current value == the expected value.
ICompletableFuture<Boolean>	AsyncAtomicReference.asyncContains(E value) Deprecated. Checks if the reference contains the value.
ICompletableFuture<Long>	AsyncAtomicLong.asyncDecrementAndGet() Deprecated. Atomically decrements the current value by one.
ICompletableFuture<Long>	AsyncAtomicLong.asyncGet() Deprecated. Gets the current value.
ICompletableFuture<E>	AsyncAtomicReference.asyncGet() Deprecated. Gets the current value.
ICompletableFuture<Long>	AsyncAtomicLong.asyncGetAndAdd(long delta) Deprecated. Atomically adds the given value to the current value.
ICompletableFuture<E>	AsyncAtomicReference.asyncGetAndAlter(IFunction<E,E> function) Deprecated. Alters the currently stored reference by applying a function on it on and gets the old value.
ICompletableFuture<Long>	AsyncAtomicLong.asyncGetAndAlter(IFunction<Long,Long> function) Deprecated. Alters the currently stored value by applying a function on it on and gets the old value.
ICompletableFuture<Long>	AsyncAtomicLong.asyncGetAndIncrement() Deprecated. Atomically increments the current value by one.
ICompletableFuture<E>	AsyncAtomicReference.asyncGetAndSet(E newValue) Deprecated. Gets the value and sets the new value.
ICompletableFuture<Long>	AsyncAtomicLong.asyncGetAndSet(long newValue) Deprecated. Atomically sets the given value and returns the old value.
ICompletableFuture<Long>	AsyncAtomicLong.asyncIncrementAndGet() Deprecated. Atomically increments the current value by one.
ICompletableFuture<Boolean>	AsyncAtomicReference.asyncIsNull() Deprecated. Checks if the stored reference is null.
ICompletableFuture<Void>	AsyncAtomicReference.asyncSet(E newValue) Deprecated. Atomically sets the given value.
ICompletableFuture<Void>	AsyncAtomicLong.asyncSet(long newValue) Deprecated. Atomically sets the given value.
ICompletableFuture<E>	AsyncAtomicReference.asyncSetAndGet(E update) Deprecated. will be removed from Hazelcast 3.4 since it doesn't really serve a purpose.
ICompletableFuture<Void>	IAtomicReference.clearAsync() Clears the current stored reference.
ICompletableFuture<Boolean>	IAtomicReference.compareAndSetAsync(E expect, E update) Atomically sets the value to the given updated value only if the current value == the expected value.
ICompletableFuture<Boolean>	IAtomicLong.compareAndSetAsync(long expect, long update) Atomically sets the value to the given updated value only if the current value == the expected value.
ICompletableFuture<Boolean>	IAtomicReference.containsAsync(E expected) Checks if the reference contains the value.
ICompletableFuture<Long>	IAtomicLong.decrementAndGetAsync() Atomically decrements the current value by one.
ICompletableFuture<Long>	IAtomicLong.getAndAddAsync(long delta) Atomically adds the given value to the current value.
ICompletableFuture<E>	IAtomicReference.getAndAlterAsync(IFunction<E,E> function) Alters the currently stored reference by applying a function on it on and gets the old value.
ICompletableFuture<Long>	IAtomicLong.getAndAlterAsync(IFunction<Long,Long> function) Alters the currently stored value by applying a function on it on and gets the old value.
ICompletableFuture<Long>	IAtomicLong.getAndIncrementAsync() Atomically increments the current value by one.
ICompletableFuture<E>	IAtomicReference.getAndSetAsync(E newValue) Gets the value and sets the new value.
ICompletableFuture<Long>	IAtomicLong.getAndSetAsync(long newValue) Atomically sets the given value and returns the old value.
ICompletableFuture<E>	IAtomicReference.getAsync() Gets the current value.
ICompletableFuture<Long>	IAtomicLong.getAsync() Gets the current value.
ICompletableFuture<V>	IMap.getAsync(K key) Asynchronously gets the given key.
ICompletableFuture<Long>	IAtomicLong.incrementAndGetAsync() Atomically increments the current value by one.
ICompletableFuture<Boolean>	IAtomicReference.isNullAsync() Checks if the stored reference is null.
ICompletableFuture<V>	IMap.putAsync(K key, V value) Asynchronously puts the given key and value.
ICompletableFuture<V>	IMap.putAsync(K key, V value, long ttl, TimeUnit timeunit) Asynchronously puts the given key and value into this map with a given ttl (time to live) value.
ICompletableFuture<V>	IMap.removeAsync(K key) Asynchronously removes the given key, returning an ICompletableFuture on which the caller can provide an ExecutionCallback to be invoked upon remove operation completion or block waiting for the operation to complete with Future.get().
ICompletableFuture<Void>	IAtomicReference.setAsync(E newValue) Atomically sets the given value.
ICompletableFuture<Void>	IMap.setAsync(K key, V value) Asynchronously puts the given key and value.
ICompletableFuture<Void>	IMap.setAsync(K key, V value, long ttl, TimeUnit timeunit) Asynchronously puts the given key and value into this map with a given ttl (time to live) value.
ICompletableFuture<Void>	IAtomicLong.setAsync(long newValue) Atomically sets the given value.
ICompletableFuture	IMap.submitToKey(K key, EntryProcessor entryProcessor) Applies the user defined EntryProcessor to the entry mapped by the key.

Uses of ICompletableFuture in com.hazelcast.durableexecutor

Subinterfaces of ICompletableFuture in com.hazelcast.durableexecutor

Modifier and Type	Interface and Description
interface	DurableExecutorServiceFuture<V> A Future where one can obtain the task id for tracking the response

Uses of ICompletableFuture in com.hazelcast.map.impl.proxy

Methods in com.hazelcast.map.impl.proxy that return ICompletableFuture

Modifier and Type	Method and Description
ICompletableFuture	NearCachedMapProxyImpl.executeOnKeyInternal(Data key, EntryProcessor entryProcessor, ExecutionCallback<Object> callback)
ICompletableFuture<V>	MapProxyImpl.getAsync(K k)
protected ICompletableFuture<Data>	NearCachedMapProxyImpl.getAsyncInternal(Data key)
ICompletableFuture<V>	MapProxyImpl.putAsync(K key, V value)
ICompletableFuture<V>	MapProxyImpl.putAsync(K key, V value, long ttl, TimeUnit timeunit)
protected ICompletableFuture<Data>	NearCachedMapProxyImpl.putAsyncInternal(Data key, Data value, long ttl, TimeUnit timeunit)
ICompletableFuture<V>	MapProxyImpl.removeAsync(K key)
protected ICompletableFuture<Data>	NearCachedMapProxyImpl.removeAsyncInternal(Data key)
ICompletableFuture<Void>	MapProxyImpl.setAsync(K key, V value)
ICompletableFuture<Void>	MapProxyImpl.setAsync(K key, V value, long ttl, TimeUnit timeunit)
protected ICompletableFuture<Data>	NearCachedMapProxyImpl.setAsyncInternal(Data key, Data value, long ttl, TimeUnit timeunit)
ICompletableFuture	MapProxyImpl.submitToKey(K key, EntryProcessor entryProcessor)

Uses of ICompletableFuture in com.hazelcast.mapreduce

Subinterfaces of ICompletableFuture in com.hazelcast.mapreduce

Modifier and Type	Interface and Description
interface	JobCompletableFuture<V> This is a special version of ICompletableFuture to return the assigned job id of the submit operation.

Methods in com.hazelcast.mapreduce that return ICompletableFuture

Modifier and Type	Method and Description
ICompletableFuture<V>	TrackableJob.getCompletableFuture() Returns the ICompletableFuture to add callbacks or wait for the resulting value of the tracked job.

Uses of ICompletableFuture in com.hazelcast.mapreduce.impl.task

Classes in com.hazelcast.mapreduce.impl.task that implement ICompletableFuture

Modifier and Type	Class and Description
class	TrackableJobFuture<V> This is the node based implementation of the job's reactive ICompletableFuture and is returned to the users codebase.

Methods in com.hazelcast.mapreduce.impl.task that return ICompletableFuture

Modifier and Type	Method and Description
ICompletableFuture<V>	TrackableJobFuture.getCompletableFuture()

Uses of ICompletableFuture in com.hazelcast.ringbuffer

Methods in com.hazelcast.ringbuffer that return ICompletableFuture

Modifier and Type	Method and Description
ICompletableFuture<Long>	Ringbuffer.addAllAsync(Collection<? extends E> collection, OverflowPolicy overflowPolicy) Adds all the items of a collection to the tail of the Ringbuffer.
ICompletableFuture<Long>	Ringbuffer.addAsync(E item, OverflowPolicy overflowPolicy) Asynchronously writes an item with a configurable OverflowPolicy.
ICompletableFuture<ReadResultSet<E>>	Ringbuffer.readManyAsync(long startSequence, int minCount, int maxCount, IFunction<E,Boolean> filter) Reads a batch of items from the Ringbuffer.

Uses of ICompletableFuture in com.hazelcast.ringbuffer.impl

Methods in com.hazelcast.ringbuffer.impl that return ICompletableFuture

Modifier and Type	Method and Description
ICompletableFuture<Long>	RingbufferProxy.addAllAsync(Collection<? extends E> collection, OverflowPolicy overflowPolicy)
ICompletableFuture<Long>	RingbufferProxy.addAsync(E item, OverflowPolicy overflowPolicy)
ICompletableFuture<ReadResultSet<E>>	RingbufferProxy.readManyAsync(long startSequence, int minCount, int maxCount, IFunction<E,Boolean> filter)

Uses of ICompletableFuture in com.hazelcast.spi

Subinterfaces of ICompletableFuture in com.hazelcast.spi

Modifier and Type	Interface and Description
interface	InternalCompletableFuture<E> A ICompletableFuture with more functionality like getting the result without needing to deal with checked exceptions.

Methods in com.hazelcast.spi that return ICompletableFuture

Modifier and Type	Method and Description
<V> ICompletableFuture<V>	ExecutionService.asCompletableFuture(Future<V> future)

Uses of ICompletableFuture in com.hazelcast.spi.impl

Classes in com.hazelcast.spi.impl that implement ICompletableFuture

Modifier and Type	Class and Description
class	AbstractCompletableFuture<V> A base ICompletableFuture implementation that may be explicitly completed by setting its value through setResult.
class	AbstractInvocationFuture<V> todo: - thread value protection The long term goal is that this whole class can be ripped out and replaced by the java.util.concurrent.CompletableFuture.

Uses of ICompletableFuture in com.hazelcast.spi.impl.executionservice.impl

Methods in com.hazelcast.spi.impl.executionservice.impl that return ICompletableFuture

Modifier and Type	Method and Description
<V> ICompletableFuture<V>	ExecutionServiceImpl.asCompletableFuture(Future<V> future)

Uses of ICompletableFuture in com.hazelcast.util.executor

Classes in com.hazelcast.util.executor that implement ICompletableFuture

Modifier and Type	Class and Description
class	CompletableFutureTask<V>
class	CompletedFuture<V>
class	DelegatingFuture<V>

Methods in com.hazelcast.util.executor that return ICompletableFuture

Modifier and Type	Method and Description
protected ICompletableFuture	DelegatingFuture.getFuture()

Constructors in com.hazelcast.util.executor with parameters of type ICompletableFuture

Constructor and Description
DelegatingFuture(ICompletableFuture future, SerializationService serializationService)
DelegatingFuture(ICompletableFuture future, SerializationService serializationService, V defaultValue)