Package | Description |
---|---|
com.hazelcast.cache |
Hazelcast JSR-107 aka JCache implementation
|
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.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.spi |
Provides interfaces/classes for Hazelcast SPI.
|
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.util.executor |
This package contains classes related to Util.Executor
|
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 expiry policy.
|
ICompletableFuture<V> |
ICache.getAndRemoveAsync(K key)
Asynchronously removes the entry for a key returning the removed value if one existed.
|
ICompletableFuture<V> |
ICache.getAndReplaceAsync(K key,
V value)
Asynchronously replaces the entry for a key only if it is currently mapped to some value.
|
ICompletableFuture<V> |
ICache.getAndReplaceAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy)
Asynchronously replaces the entry for a key only if it is currently mapped to some value
using custom expiry policy.
|
ICompletableFuture<V> |
ICache.getAsync(K key)
Asynchronously gets an entry from cache.
|
ICompletableFuture<V> |
ICache.getAsync(K key,
javax.cache.expiry.ExpiryPolicy expiryPolicy)
Asynchronously gets an entry from cache with a provided expiry policy.
|
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 expiry policy.
|
ICompletableFuture<Boolean> |
ICache.putIfAbsentAsync(K key,
V value)
Asynchronously associates the specified value with the specified key in the cache if not already exist.
|
ICompletableFuture<Boolean> |
ICache.putIfAbsentAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy)
Asynchronously associates the specified value with the specified key in the cache if not already exist,
using a custom expiry policy.
|
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 a key only if it is currently mapped to the
given value.
|
ICompletableFuture<Boolean> |
ICache.replaceAsync(K key,
V value)
Asynchronously replaces the entry for a key.
|
ICompletableFuture<Boolean> |
ICache.replaceAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy)
Asynchronously replaces the entry for a key only if it is currently mapped to some
value.
|
ICompletableFuture<Boolean> |
ICache.replaceAsync(K key,
V oldValue,
V newValue)
Asynchronously replaces the entry for a key only if it is currently mapped to a
given value.
|
ICompletableFuture<Boolean> |
ICache.replaceAsync(K key,
V oldValue,
V newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy)
Asynchronously replaces the entry for a key only if it is currently mapped to a
given value using custom expiry policy.
|
Modifier and Type | Method and Description |
---|---|
<T> ICompletableFuture<T> |
ClientInvocationService.invokeOnKeyOwner(ClientRequest request,
Object key) |
<T> ICompletableFuture<T> |
ClientInvocationService.invokeOnKeyOwner(ClientRequest request,
Object key,
EventHandler handler) |
<T> ICompletableFuture<T> |
ClientInvocationService.invokeOnPartitionOwner(ClientRequest request,
int partitionId) |
<T> ICompletableFuture<T> |
ClientInvocationService.invokeOnRandomTarget(ClientRequest request) |
<T> ICompletableFuture<T> |
ClientInvocationService.invokeOnRandomTarget(ClientRequest request,
EventHandler handler) |
<T> ICompletableFuture<T> |
ClientInvocationService.invokeOnTarget(ClientRequest request,
Address target) |
<T> ICompletableFuture<T> |
ClientInvocationService.invokeOnTarget(ClientRequest request,
Address target,
EventHandler handler) |
<T> ICompletableFuture<T> |
ClientExecutionService.submit(Callable<T> task) |
ICompletableFuture<?> |
ClientExecutionService.submit(Runnable task) |
Modifier and Type | Class and Description |
---|---|
class |
ClientCallFuture<V> |
Modifier and Type | Method and Description |
---|---|
<T> ICompletableFuture<T> |
ClientInvocationServiceImpl.invokeOnKeyOwner(ClientRequest request,
Object key) |
<T> ICompletableFuture<T> |
ClientInvocationServiceImpl.invokeOnKeyOwner(ClientRequest request,
Object key,
EventHandler handler) |
<T> ICompletableFuture<T> |
ClientInvocationServiceImpl.invokeOnPartitionOwner(ClientRequest request,
int partitionId) |
<T> ICompletableFuture<T> |
ClientInvocationServiceImpl.invokeOnRandomTarget(ClientRequest request) |
<T> ICompletableFuture<T> |
ClientInvocationServiceImpl.invokeOnRandomTarget(ClientRequest request,
EventHandler handler) |
<T> ICompletableFuture<T> |
ClientInvocationServiceImpl.invokeOnTarget(ClientRequest request,
Address target) |
<T> ICompletableFuture<T> |
ClientInvocationServiceImpl.invokeOnTarget(ClientRequest request,
Address target,
EventHandler handler) |
ICompletableFuture |
ClientInvocationServiceImpl.send(ClientRequest request,
ClientConnection connection) |
<T> ICompletableFuture<T> |
ClientExecutionServiceImpl.submit(Callable<T> task) |
ICompletableFuture<?> |
ClientExecutionServiceImpl.submit(Runnable task) |
<T> ICompletableFuture<T> |
ClientExecutionServiceImpl.submitInternal(Callable<T> command) |
Modifier and Type | Class and Description |
---|---|
class |
ClientCancellableDelegatingFuture<V>
A DelegatingFuture that can cancel a Runnable/Callable that is executed by an
IExecutorService . |
Constructor and Description |
---|
ClientCancellableDelegatingFuture(ICompletableFuture future,
ClientContext context,
String uuid,
Address target,
int partitionId) |
ClientCancellableDelegatingFuture(ICompletableFuture future,
ClientContext context,
String uuid,
Address target,
int partitionId,
V defaultValue) |
Modifier and Type | Method and Description |
---|---|
ICompletableFuture |
MapProxyImpl.putAsync(K key,
V value,
long ttl,
TimeUnit timeunit) |
ICompletableFuture |
MapProxyImpl.removeAsync(K key) |
ICompletableFuture |
MapProxyImpl.submitToKey(K key,
EntryProcessor entryProcessor) |
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.
|
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 |
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. |
Modifier and Type | Method and Description |
---|---|
ICompletableFuture<V> |
TrackableJobFuture.getCompletableFuture() |
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. |
Modifier and Type | Method and Description |
---|---|
<V> ICompletableFuture<V> |
ExecutionService.asCompletableFuture(Future<V> future) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCompletableFuture<V> |
Modifier and Type | Method and Description |
---|---|
<V> ICompletableFuture<V> |
ExecutionServiceImpl.asCompletableFuture(Future<V> future) |
Modifier and Type | Class and Description |
---|---|
class |
CompletableFutureTask<V> |
class |
CompletedFuture<V> |
class |
DelegatingFuture<V> |
Constructor and Description |
---|
DelegatingFuture(ICompletableFuture future,
SerializationService serializationService) |
DelegatingFuture(ICompletableFuture future,
SerializationService serializationService,
V defaultValue) |
Copyright © 2014 Hazelcast, Inc.. All Rights Reserved.