Uses of Interface
com.hazelcast.spi.InternalCompletableFuture

Packages that use InternalCompletableFuture

Package	Description
com.hazelcast.client.cache.impl.nearcache.invalidation
com.hazelcast.client.map.impl.nearcache.invalidation
com.hazelcast.client.proxy	This package contains client side proxy implementations of the different Hazelcast data structures and operation types
com.hazelcast.client.spi.impl	Provides util classes for the Hazelcast client SPI.
com.hazelcast.client.util	This package contains some utility classes and the base implementations of the loadbalancer implementations
com.hazelcast.concurrent.atomiclong	This package contains IAtomicLong functionality for Hazelcast. The IAtomicLong is the distributed version of the AtomicLong.
com.hazelcast.concurrent.atomicreference	This package contains IAtomicReferece functionality for Hazelcast. The IAtomicReference is the distributed version of the AtomicReference.
com.hazelcast.internal.nearcache.impl.invalidation	Invalidations for near-cache
com.hazelcast.map.impl.nearcache.invalidation
com.hazelcast.map.impl.proxy	Contains map proxy implementation and support 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.operationservice.impl	Contains the code for the InternalOperationService implementation.
com.hazelcast.util.executor	This package contains classes related to Util.Executor

Uses of InternalCompletableFuture in com.hazelcast.client.cache.impl.nearcache.invalidation

Methods in com.hazelcast.client.cache.impl.nearcache.invalidation that return types with arguments of type InternalCompletableFuture

Modifier and Type	Method and Description
protected List<InternalCompletableFuture>	ClientCacheMetaDataFetcher.scanMembers(List<String> names)

Methods in com.hazelcast.client.cache.impl.nearcache.invalidation with parameters of type InternalCompletableFuture

Modifier and Type	Method and Description
protected void	ClientCacheMetaDataFetcher.process(InternalCompletableFuture future, ConcurrentMap<String,RepairingHandler> handlers)

Uses of InternalCompletableFuture in com.hazelcast.client.map.impl.nearcache.invalidation

Methods in com.hazelcast.client.map.impl.nearcache.invalidation that return types with arguments of type InternalCompletableFuture

Modifier and Type	Method and Description
protected List<InternalCompletableFuture>	ClientMapMetaDataFetcher.scanMembers(List<String> names)

Methods in com.hazelcast.client.map.impl.nearcache.invalidation with parameters of type InternalCompletableFuture

Modifier and Type	Method and Description
protected void	ClientMapMetaDataFetcher.process(InternalCompletableFuture future, ConcurrentMap<String,RepairingHandler> handlers)

Uses of InternalCompletableFuture in com.hazelcast.client.proxy

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

Modifier and Type	Method and Description
InternalCompletableFuture<Long>	ClientAtomicLongProxy.addAndGetAsync(long delta)
InternalCompletableFuture<Void>	ClientCardinalityEstimatorProxy.addAsync(Object obj)
InternalCompletableFuture<E>	ClientAtomicReferenceProxy.alterAndGetAsync(IFunction<E,E> function)
InternalCompletableFuture<Long>	ClientAtomicLongProxy.alterAndGetAsync(IFunction<Long,Long> function)
InternalCompletableFuture<Void>	ClientAtomicReferenceProxy.alterAsync(IFunction<E,E> function)
InternalCompletableFuture<Void>	ClientAtomicLongProxy.alterAsync(IFunction<Long,Long> function)
<R> InternalCompletableFuture<R>	ClientAtomicReferenceProxy.applyAsync(IFunction<E,R> function)
<R> InternalCompletableFuture<R>	ClientAtomicLongProxy.applyAsync(IFunction<Long,R> function)
InternalCompletableFuture<Void>	ClientAtomicReferenceProxy.clearAsync()
InternalCompletableFuture<Boolean>	ClientAtomicReferenceProxy.compareAndSetAsync(E expect, E update)
InternalCompletableFuture<Boolean>	ClientAtomicLongProxy.compareAndSetAsync(long expect, long update)
InternalCompletableFuture<Boolean>	ClientAtomicReferenceProxy.containsAsync(E expected)
InternalCompletableFuture<Long>	ClientAtomicLongProxy.decrementAndGetAsync()
InternalCompletableFuture<Long>	ClientCardinalityEstimatorProxy.estimateAsync()
InternalCompletableFuture<Long>	ClientAtomicLongProxy.getAndAddAsync(long delta)
InternalCompletableFuture<E>	ClientAtomicReferenceProxy.getAndAlterAsync(IFunction<E,E> function)
InternalCompletableFuture<Long>	ClientAtomicLongProxy.getAndAlterAsync(IFunction<Long,Long> function)
InternalCompletableFuture<Long>	ClientAtomicLongProxy.getAndIncrementAsync()
InternalCompletableFuture<E>	ClientAtomicReferenceProxy.getAndSetAsync(E newValue)
InternalCompletableFuture<Long>	ClientAtomicLongProxy.getAndSetAsync(long newValue)
InternalCompletableFuture<Long>	ClientAtomicLongProxy.getAsync()
InternalCompletableFuture<E>	ClientAtomicReferenceProxy.getAsync()
InternalCompletableFuture<Long>	ClientAtomicLongProxy.incrementAndGetAsync()
InternalCompletableFuture<Boolean>	ClientAtomicReferenceProxy.isNullAsync()
InternalCompletableFuture<Void>	ClientAtomicReferenceProxy.setAsync(E newValue)
InternalCompletableFuture<Void>	ClientAtomicLongProxy.setAsync(long newValue)

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

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

Modifier and Type	Class and Description
class	ClientInvocationFuture

Uses of InternalCompletableFuture in com.hazelcast.client.util

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

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 InternalCompletableFuture in com.hazelcast.concurrent.atomiclong

Methods in com.hazelcast.concurrent.atomiclong that return InternalCompletableFuture

Modifier and Type	Method and Description
InternalCompletableFuture<Long>	AtomicLongProxy.addAndGetAsync(long delta)
InternalCompletableFuture<Long>	AtomicLongProxy.alterAndGetAsync(IFunction<Long,Long> function)
InternalCompletableFuture<Void>	AtomicLongProxy.alterAsync(IFunction<Long,Long> function)
<R> InternalCompletableFuture<R>	AtomicLongProxy.applyAsync(IFunction<Long,R> function)
InternalCompletableFuture<Long>	AtomicLongProxy.asyncAddAndGet(long delta)
InternalCompletableFuture<Void>	AtomicLongProxy.asyncAlter(IFunction<Long,Long> function)
InternalCompletableFuture<Long>	AtomicLongProxy.asyncAlterAndGet(IFunction<Long,Long> function)
<R> InternalCompletableFuture<R>	AtomicLongProxy.asyncApply(IFunction<Long,R> function)
InternalCompletableFuture<Boolean>	AtomicLongProxy.asyncCompareAndSet(long expect, long update)
InternalCompletableFuture<Long>	AtomicLongProxy.asyncDecrementAndGet()
InternalCompletableFuture<Long>	AtomicLongProxy.asyncGet()
InternalCompletableFuture<Long>	AtomicLongProxy.asyncGetAndAdd(long delta)
InternalCompletableFuture<Long>	AtomicLongProxy.asyncGetAndAlter(IFunction<Long,Long> function)
InternalCompletableFuture<Long>	AtomicLongProxy.asyncGetAndIncrement()
InternalCompletableFuture<Long>	AtomicLongProxy.asyncGetAndSet(long newValue)
InternalCompletableFuture<Long>	AtomicLongProxy.asyncIncrementAndGet()
InternalCompletableFuture<Void>	AtomicLongProxy.asyncSet(long newValue)
InternalCompletableFuture<Boolean>	AtomicLongProxy.compareAndSetAsync(long expect, long update)
InternalCompletableFuture<Long>	AtomicLongProxy.decrementAndGetAsync()
InternalCompletableFuture<Long>	AtomicLongProxy.getAndAddAsync(long delta)
InternalCompletableFuture<Long>	AtomicLongProxy.getAndAlterAsync(IFunction<Long,Long> function)
InternalCompletableFuture<Long>	AtomicLongProxy.getAndIncrementAsync()
InternalCompletableFuture<Long>	AtomicLongProxy.getAndSetAsync(long newValue)
InternalCompletableFuture<Long>	AtomicLongProxy.getAsync()
InternalCompletableFuture<Long>	AtomicLongProxy.incrementAndGetAsync()
InternalCompletableFuture<Void>	AtomicLongProxy.setAsync(long newValue)

Uses of InternalCompletableFuture in com.hazelcast.concurrent.atomicreference

Methods in com.hazelcast.concurrent.atomicreference that return InternalCompletableFuture

Modifier and Type	Method and Description
InternalCompletableFuture<E>	AtomicReferenceProxy.alterAndGetAsync(IFunction<E,E> function)
InternalCompletableFuture<Void>	AtomicReferenceProxy.alterAsync(IFunction<E,E> function)
<R> InternalCompletableFuture<R>	AtomicReferenceProxy.applyAsync(IFunction<E,R> function)
InternalCompletableFuture<Void>	AtomicReferenceProxy.asyncAlter(IFunction<E,E> function)
InternalCompletableFuture<E>	AtomicReferenceProxy.asyncAlterAndGet(IFunction<E,E> function)
<R> InternalCompletableFuture<R>	AtomicReferenceProxy.asyncApply(IFunction<E,R> function)
InternalCompletableFuture<Void>	AtomicReferenceProxy.asyncClear()
InternalCompletableFuture<Boolean>	AtomicReferenceProxy.asyncCompareAndSet(E expect, E update)
InternalCompletableFuture<Boolean>	AtomicReferenceProxy.asyncContains(E value)
InternalCompletableFuture<E>	AtomicReferenceProxy.asyncGet()
InternalCompletableFuture<E>	AtomicReferenceProxy.asyncGetAndAlter(IFunction<E,E> function)
InternalCompletableFuture<E>	AtomicReferenceProxy.asyncGetAndSet(E newValue)
InternalCompletableFuture<Boolean>	AtomicReferenceProxy.asyncIsNull()
InternalCompletableFuture<Void>	AtomicReferenceProxy.asyncSet(E newValue)
InternalCompletableFuture<E>	AtomicReferenceProxy.asyncSetAndGet(E update)
InternalCompletableFuture<Void>	AtomicReferenceProxy.clearAsync()
InternalCompletableFuture<Boolean>	AtomicReferenceProxy.compareAndSetAsync(E expect, E update)
InternalCompletableFuture<Boolean>	AtomicReferenceProxy.containsAsync(E expected)
InternalCompletableFuture<E>	AtomicReferenceProxy.getAndAlterAsync(IFunction<E,E> function)
InternalCompletableFuture<E>	AtomicReferenceProxy.getAndSetAsync(E newValue)
InternalCompletableFuture<E>	AtomicReferenceProxy.getAsync()
InternalCompletableFuture<Boolean>	AtomicReferenceProxy.isNullAsync()
InternalCompletableFuture<Void>	AtomicReferenceProxy.setAsync(E newValue)

Uses of InternalCompletableFuture in com.hazelcast.internal.nearcache.impl.invalidation

Methods in com.hazelcast.internal.nearcache.impl.invalidation that return types with arguments of type InternalCompletableFuture

Modifier and Type	Method and Description
protected abstract List<InternalCompletableFuture>	MetaDataFetcher.scanMembers(List<String> names)

Methods in com.hazelcast.internal.nearcache.impl.invalidation with parameters of type InternalCompletableFuture

Modifier and Type	Method and Description
protected abstract void	MetaDataFetcher.process(InternalCompletableFuture future, ConcurrentMap<String,RepairingHandler> handlers)

Uses of InternalCompletableFuture in com.hazelcast.map.impl.nearcache.invalidation

Methods in com.hazelcast.map.impl.nearcache.invalidation that return types with arguments of type InternalCompletableFuture

Modifier and Type	Method and Description
protected List<InternalCompletableFuture>	MemberMapMetaDataFetcher.scanMembers(List<String> names)

Methods in com.hazelcast.map.impl.nearcache.invalidation with parameters of type InternalCompletableFuture

Modifier and Type	Method and Description
protected void	MemberMapMetaDataFetcher.process(InternalCompletableFuture future, ConcurrentMap<String,RepairingHandler> handlers)

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

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

Modifier and Type	Method and Description
InternalCompletableFuture<Object>	NearCachedMapProxyImpl.executeOnKeyInternal(Data key, EntryProcessor entryProcessor, ExecutionCallback<Object> callback)
protected InternalCompletableFuture<Data>	NearCachedMapProxyImpl.getAsyncInternal(Data key)
protected InternalCompletableFuture<Data>	NearCachedMapProxyImpl.putAsyncInternal(Data key, Data value, long ttl, TimeUnit timeunit)
protected InternalCompletableFuture<Data>	NearCachedMapProxyImpl.removeAsyncInternal(Data key)
protected InternalCompletableFuture<Data>	NearCachedMapProxyImpl.setAsyncInternal(Data key, Data value, long ttl, TimeUnit timeunit)

Uses of InternalCompletableFuture in com.hazelcast.spi

Methods in com.hazelcast.spi that return InternalCompletableFuture

Modifier and Type	Method and Description
abstract <E> InternalCompletableFuture<E>	InvocationBuilder.invoke()
<E> InternalCompletableFuture<E>	OperationService.invokeOnPartition(Operation op) Executes an operation on a partition.
protected <E> InternalCompletableFuture<E>	AbstractDistributedObject.invokeOnPartition(Operation operation)
<E> InternalCompletableFuture<E>	OperationService.invokeOnPartition(String serviceName, Operation op, int partitionId)
<E> InternalCompletableFuture<E>	OperationService.invokeOnTarget(String serviceName, Operation op, Address target)

Uses of InternalCompletableFuture in com.hazelcast.spi.impl

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

Modifier and Type	Class and Description
class	AbstractInvocationFuture<V> Custom implementation of CompletableFuture.

Uses of InternalCompletableFuture in com.hazelcast.spi.impl.operationservice.impl

Methods in com.hazelcast.spi.impl.operationservice.impl that return InternalCompletableFuture

Modifier and Type	Method and Description
<E> InternalCompletableFuture<E>	OperationServiceImpl.invokeOnPartition(Operation op)
<E> InternalCompletableFuture<E>	OperationServiceImpl.invokeOnPartition(String serviceName, Operation op, int partitionId)
<E> InternalCompletableFuture<E>	OperationServiceImpl.invokeOnTarget(String serviceName, Operation op, Address target)

Uses of InternalCompletableFuture in com.hazelcast.util.executor

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

Modifier and Type	Class and Description
class	CompletedFuture<V>
class	DelegatingFuture<V> A InternalCompletableFuture implementation that delegates the real logic to an underlying InternalCompletableFuture and decorates it with additional behavior: change the returned value by setting the result always deserializing the content caching the deserialized content so that a deserialization only happens once.

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

Constructor and Description
DelegatingFuture(InternalCompletableFuture future, SerializationService serializationService)
DelegatingFuture(InternalCompletableFuture future, SerializationService serializationService, V result) Creates a DelegatingFuture