| 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.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.ringbuffer |
Contains the API for the
Ringbuffer. |
| com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
| com.hazelcast.spi |
Provides interfaces/classes for Hazelcast SPI.
|
| 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
|
| 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. |
| Modifier and Type | Method and Description |
|---|---|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncAddAndGet(long delta)
Atomically adds the given value to the current value.
|
ICompletableFuture<Void> |
AsyncAtomicReference.asyncAlter(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it.
|
ICompletableFuture<Void> |
AsyncAtomicLong.asyncAlter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it.
|
ICompletableFuture<E> |
AsyncAtomicReference.asyncAlterAndGet(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it and gets the result.
|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncAlterAndGet(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it and gets the result.
|
<R> ICompletableFuture<R> |
AsyncAtomicReference.asyncApply(IFunction<E,R> function)
Applies a function on the value, the actual stored value will not change.
|
<R> ICompletableFuture<R> |
AsyncAtomicLong.asyncApply(IFunction<Long,R> function)
Applies a function on the value, the actual stored value will not change.
|
ICompletableFuture<Void> |
AsyncAtomicReference.asyncClear()
Clears the current stored reference.
|
ICompletableFuture<Boolean> |
AsyncAtomicReference.asyncCompareAndSet(E expect,
E update)
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)
Atomically sets the value to the given updated value
only if the current value
== the expected value. |
ICompletableFuture<Boolean> |
AsyncAtomicReference.asyncContains(E value)
Checks if the reference contains the value.
|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncDecrementAndGet()
Atomically decrements the current value by one.
|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncGet()
Gets the current value.
|
ICompletableFuture<E> |
AsyncAtomicReference.asyncGet()
Gets the current value.
|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncGetAndAdd(long delta)
Atomically adds the given value to the current value.
|
ICompletableFuture<E> |
AsyncAtomicReference.asyncGetAndAlter(IFunction<E,E> function)
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)
Alters the currently stored value by applying a function on it on and gets the old value.
|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncGetAndIncrement()
Atomically increments the current value by one.
|
ICompletableFuture<E> |
AsyncAtomicReference.asyncGetAndSet(E newValue)
Gets the value and sets the new value.
|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncGetAndSet(long newValue)
Atomically sets the given value and returns the old value.
|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncIncrementAndGet()
Atomically increments the current value by one.
|
ICompletableFuture<Boolean> |
AsyncAtomicReference.asyncIsNull()
Checks if the stored reference is null.
|
ICompletableFuture<Void> |
AsyncAtomicReference.asyncSet(E newValue)
Atomically sets the given value.
|
ICompletableFuture<Void> |
AsyncAtomicLong.asyncSet(long newValue)
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.
|
| Modifier and Type | Method and Description |
|---|---|
ICompletableFuture |
NearCachedMapProxyImpl.executeOnKeyInternal(Data key,
EntryProcessor entryProcessor,
ExecutionCallback callback) |
protected ICompletableFuture<Data> |
NearCachedMapProxyImpl.getAsyncInternal(Data key) |
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 |
MapProxyImpl.removeAsync(K key) |
protected ICompletableFuture<Data> |
NearCachedMapProxyImpl.removeAsyncInternal(Data key) |
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) |
| 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 | 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.
|
| 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) |
| 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>
A base
ICompletableFuture implementation that may be explicitly completed by setting its
value through setResult. |
| 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> |
| Modifier and Type | Method and Description |
|---|---|
protected ICompletableFuture |
DelegatingFuture.getFuture() |
| Constructor and Description |
|---|
DelegatingFuture(ICompletableFuture future,
SerializationService serializationService) |
DelegatingFuture(ICompletableFuture future,
SerializationService serializationService,
V defaultValue) |
Copyright © 2016. All Rights Reserved.