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.cp.internal |
Contains implementation of the CP subsystem
|
com.hazelcast.cp.internal.datastructures.atomiclong.proxy |
Contains
IAtomicLong functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.atomicref.proxy |
Contains
IAtomicReference functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.lock.proxy |
Contains
ILock functionality
based on the Raft algorithm. |
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.internal.util |
This package contains classes to support the inner workings of Hazelcast
as well as some backports of newer Java features / data structures to
support older Java versions in a clean and nice way.
|
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 InternalCompletableFuture |
ClientCacheInvalidationMetaDataFetcher.fetchMetadataOf(Address address,
List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientCacheInvalidationMetaDataFetcher.extractMemberMetadata(Member member,
InternalCompletableFuture future,
InvalidationMetaDataFetcher.MetadataHolder metadataHolder) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture |
ClientMapInvalidationMetaDataFetcher.fetchMetadataOf(Address address,
List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientMapInvalidationMetaDataFetcher.extractMemberMetadata(Member member,
InternalCompletableFuture future,
InvalidationMetaDataFetcher.MetadataHolder metadataHolder) |
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>
The Client Delegating Future is used to delegate
ClientInvocationFuture to a user type to be used with andThen() or
get() . |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<Object> |
RaftInvocationManager.destroy(CPGroupId groupId) |
<T> InternalCompletableFuture<T> |
RaftInvocationManager.invoke(CPGroupId groupId,
RaftOp raftOp) |
<T> InternalCompletableFuture<T> |
RaftInvocationManager.query(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
<T> InternalCompletableFuture<T> |
RaftInvocationManager.queryLocally(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
Modifier and Type | Method and Description |
---|---|
protected abstract InternalCompletableFuture<RaftLockOwnershipState> |
AbstractRaftFencedLockProxy.doGetLockOwnershipState() |
protected InternalCompletableFuture<RaftLockOwnershipState> |
RaftFencedLockProxy.doGetLockOwnershipState() |
protected abstract InternalCompletableFuture<Long> |
AbstractRaftFencedLockProxy.doLock(long sessionId,
long threadId,
UUID invocationUid) |
protected InternalCompletableFuture<Long> |
RaftFencedLockProxy.doLock(long sessionId,
long threadId,
UUID invocationUid) |
protected abstract InternalCompletableFuture<Long> |
AbstractRaftFencedLockProxy.doTryLock(long sessionId,
long threadId,
UUID invocationUid,
long timeoutMillis) |
protected InternalCompletableFuture<Long> |
RaftFencedLockProxy.doTryLock(long sessionId,
long threadId,
UUID invocationUid,
long timeoutMillis) |
protected abstract InternalCompletableFuture<Boolean> |
AbstractRaftFencedLockProxy.doUnlock(long sessionId,
long threadId,
UUID invocationUid) |
protected InternalCompletableFuture<Boolean> |
RaftFencedLockProxy.doUnlock(long sessionId,
long threadId,
UUID invocationUid) |
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 InternalCompletableFuture |
InvalidationMetaDataFetcher.fetchMetadataOf(Address address,
List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
InvalidationMetaDataFetcher.extractMemberMetadata(Member member,
InternalCompletableFuture future,
InvalidationMetaDataFetcher.MetadataHolder metadataHolder) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleCompletableFuture<T>
Generic implementation of
InternalCompletableFuture . |
class |
SimpleCompletedFuture<E>
Generic implementation of a completed
InternalCompletableFuture . |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture |
MemberMapInvalidationMetaDataFetcher.fetchMetadataOf(Address address,
List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
MemberMapInvalidationMetaDataFetcher.extractMemberMetadata(Member member,
InternalCompletableFuture future,
InvalidationMetaDataFetcher.MetadataHolder metadataHolder) |
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 ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.removeAsyncInternal(Object key) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.setAsyncInternal(Object key,
Data value,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
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 © 2019 Hazelcast, Inc.. All Rights Reserved.