Package | Description |
---|---|
com.hazelcast.cardinality.impl | |
com.hazelcast.client.cache.impl |
Hazelcast JSR-107 aka JCache implementation client side
|
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.management |
Contains classes to provide data/operation interface for Management Center.
|
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
|
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<Void> |
CardinalityEstimatorProxy.addAsync(Object obj) |
InternalCompletableFuture<Long> |
CardinalityEstimatorProxy.estimateAsync() |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture<V> |
NearCachedClientCacheProxy.getAsyncInternal(Object key,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
ExecutionCallback<V> callback) |
Modifier and Type | Method and Description |
---|---|
protected List<InternalCompletableFuture> |
ClientCacheMetaDataFetcher.scanMembers(List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientCacheMetaDataFetcher.extractAndPopulateResult(InternalCompletableFuture future,
MetaDataFetcher.ResultHolder resultHolder) |
Modifier and Type | Method and Description |
---|---|
protected List<InternalCompletableFuture> |
ClientMapMetaDataFetcher.scanMembers(List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientMapMetaDataFetcher.extractAndPopulateResult(InternalCompletableFuture future,
MetaDataFetcher.ResultHolder resultHolder) |
Modifier and Type | Class and Description |
---|---|
class |
IExecutorDelegatingFuture<V>
An Abstract DelegatingFuture that can cancel a Runnable/Callable that is executed by an
IExecutorService . |
Modifier and Type | Class and Description |
---|---|
class |
ClientInvocationFuture |
Modifier and Type | Class and Description |
---|---|
class |
ClientDelegatingFuture<V>
Client Delegating Future is used to delegate ClientInvocationFuture to user to be used with
andThen or get.
|
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<Object> |
ManagementCenterService.callOnAddress(Address address,
Operation operation) |
InternalCompletableFuture<Object> |
ManagementCenterService.callOnMember(Member member,
Operation operation) |
InternalCompletableFuture<Object> |
ManagementCenterService.callOnThis(Operation operation) |
Modifier and Type | Method and Description |
---|---|
protected abstract List<InternalCompletableFuture> |
MetaDataFetcher.scanMembers(List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
MetaDataFetcher.extractAndPopulateResult(InternalCompletableFuture future,
MetaDataFetcher.ResultHolder resultHolder) |
void |
MetaDataFetcher.process(InternalCompletableFuture future,
ConcurrentMap<String,RepairingHandler> handlers) |
Modifier and Type | Method and Description |
---|---|
protected List<InternalCompletableFuture> |
MemberMapMetaDataFetcher.scanMembers(List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
MemberMapMetaDataFetcher.extractAndPopulateResult(InternalCompletableFuture future,
MetaDataFetcher.ResultHolder resultHolder) |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<Object> |
NearCachedMapProxyImpl.executeOnKeyInternal(Object key,
EntryProcessor entryProcessor,
ExecutionCallback<Object> callback) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.getAsyncInternal(Object key) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.putAsyncInternal(Object key,
Data value,
long ttl,
TimeUnit timeunit) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.removeAsyncInternal(Object key) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.setAsyncInternal(Object key,
Data value,
long ttl,
TimeUnit timeunit) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractInvocationFuture<V>
Custom implementation of
CompletableFuture . |
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) |
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. |
Constructor and Description |
---|
DelegatingFuture(InternalCompletableFuture future,
SerializationService serializationService) |
DelegatingFuture(InternalCompletableFuture future,
SerializationService serializationService,
V result)
Creates a DelegatingFuture
|
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.