Package | Description |
---|---|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.concurrent.atomiclong |
This package contains IAtomicLong functionality for Hazelcast.
The IAtomicLong is the distributed version of the AtomicLong . |
com.hazelcast.concurrent.atomiclong.operations |
This package contains the operations on the IAtomicLong.
|
com.hazelcast.concurrent.atomicreference |
This package contains IAtomicReferece functionality for Hazelcast.
The IAtomicReference is the distributed version of the AtomicReference . |
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.ringbuffer |
Contains the API for the
Ringbuffer . |
com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
com.hazelcast.ringbuffer.impl.operations | |
com.hazelcast.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.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientAtomicReferenceProxy.alter(IFunction<E,E> function) |
void |
ClientAtomicLongProxy.alter(IFunction<Long,Long> function) |
E |
ClientAtomicReferenceProxy.alterAndGet(IFunction<E,E> function) |
long |
ClientAtomicLongProxy.alterAndGet(IFunction<Long,Long> function) |
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> R |
ClientAtomicReferenceProxy.apply(IFunction<E,R> function) |
<R> R |
ClientAtomicLongProxy.apply(IFunction<Long,R> function) |
<R> InternalCompletableFuture<R> |
ClientAtomicReferenceProxy.applyAsync(IFunction<E,R> function) |
<R> InternalCompletableFuture<R> |
ClientAtomicLongProxy.applyAsync(IFunction<Long,R> function) |
E |
ClientAtomicReferenceProxy.getAndAlter(IFunction<E,E> function) |
long |
ClientAtomicLongProxy.getAndAlter(IFunction<Long,Long> function) |
InternalCompletableFuture<E> |
ClientAtomicReferenceProxy.getAndAlterAsync(IFunction<E,E> function) |
InternalCompletableFuture<Long> |
ClientAtomicLongProxy.getAndAlterAsync(IFunction<Long,Long> function) |
ICompletableFuture<ReadResultSet<E>> |
ClientRingbufferProxy.readManyAsync(long startSequence,
int minCount,
int maxCount,
IFunction<E,Boolean> filter) |
Modifier and Type | Field and Description |
---|---|
protected IFunction<Long,Long> |
AbstractAlterOperation.function |
Constructor and Description |
---|
AbstractAlterOperation(String name,
IFunction<Long,Long> function) |
AlterAndGetOperation(String name,
IFunction<Long,Long> function) |
AlterOperation(String name,
IFunction<Long,Long> function) |
ApplyOperation(String name,
IFunction<Long,R> function) |
GetAndAlterOperation(String name,
IFunction<Long,Long> function) |
Modifier and Type | Method and Description |
---|---|
void |
AtomicReferenceProxy.alter(IFunction<E,E> function) |
E |
AtomicReferenceProxy.alterAndGet(IFunction<E,E> function) |
InternalCompletableFuture<E> |
AtomicReferenceProxy.alterAndGetAsync(IFunction<E,E> function) |
InternalCompletableFuture<Void> |
AtomicReferenceProxy.alterAsync(IFunction<E,E> function) |
<R> R |
AtomicReferenceProxy.apply(IFunction<E,R> 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<E> |
AtomicReferenceProxy.asyncGetAndAlter(IFunction<E,E> function) |
E |
AtomicReferenceProxy.getAndAlter(IFunction<E,E> function) |
InternalCompletableFuture<E> |
AtomicReferenceProxy.getAndAlterAsync(IFunction<E,E> function) |
Modifier and Type | Method and Description |
---|---|
void |
IAtomicReference.alter(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it.
|
void |
IAtomicLong.alter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it.
|
E |
IAtomicReference.alterAndGet(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it and gets the result.
|
long |
IAtomicLong.alterAndGet(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it and gets the result.
|
ICompletableFuture<E> |
IAtomicReference.alterAndGetAsync(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it and gets the result.
|
ICompletableFuture<Long> |
IAtomicLong.alterAndGetAsync(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it and gets the result.
|
ICompletableFuture<Void> |
IAtomicReference.alterAsync(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it.
|
ICompletableFuture<Void> |
IAtomicLong.alterAsync(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it.
|
<R> R |
IAtomicReference.apply(IFunction<E,R> function)
Applies a function on the value, the actual stored value will not change.
|
<R> R |
IAtomicLong.apply(IFunction<Long,R> function)
Applies a function on the value, the actual stored value will not change.
|
<R> ICompletableFuture<R> |
IAtomicReference.applyAsync(IFunction<E,R> function)
Applies a function on the value, the actual stored value will not change.
|
<R> ICompletableFuture<R> |
IAtomicLong.applyAsync(IFunction<Long,R> function)
Applies a function on the value, the actual stored value will not change.
|
ICompletableFuture<Void> |
AsyncAtomicReference.asyncAlter(IFunction<E,E> function)
Deprecated.
Alters the currently stored reference by applying a function on it.
|
ICompletableFuture<Void> |
AsyncAtomicLong.asyncAlter(IFunction<Long,Long> function)
Deprecated.
Alters the currently stored value by applying a function on it.
|
ICompletableFuture<E> |
AsyncAtomicReference.asyncAlterAndGet(IFunction<E,E> function)
Deprecated.
Alters the currently stored reference by applying a function on it and gets the result.
|
ICompletableFuture<Long> |
AsyncAtomicLong.asyncAlterAndGet(IFunction<Long,Long> function)
Deprecated.
Alters the currently stored value by applying a function on it and gets the result.
|
<R> ICompletableFuture<R> |
AsyncAtomicReference.asyncApply(IFunction<E,R> function)
Deprecated.
Applies a function on the value, the actual stored value will not change.
|
<R> ICompletableFuture<R> |
AsyncAtomicLong.asyncApply(IFunction<Long,R> function)
Deprecated.
Applies a function on the value, the actual stored value will not change.
|
ICompletableFuture<E> |
AsyncAtomicReference.asyncGetAndAlter(IFunction<E,E> function)
Deprecated.
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)
Deprecated.
Alters the currently stored value by applying a function on it on and gets the old value.
|
E |
IAtomicReference.getAndAlter(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it on and gets the old value.
|
long |
IAtomicLong.getAndAlter(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it on and gets the old value.
|
ICompletableFuture<E> |
IAtomicReference.getAndAlterAsync(IFunction<E,E> function)
Alters the currently stored reference by applying a function on it on and gets the old value.
|
ICompletableFuture<Long> |
IAtomicLong.getAndAlterAsync(IFunction<Long,Long> function)
Alters the currently stored value by applying a function on it on and gets the old value.
|
Modifier and Type | Field and Description |
---|---|
protected IFunction<Object,Data> |
MapContainer.toDataFunction |
Modifier and Type | Method and Description |
---|---|
IFunction<Object,Data> |
MapContainer.toData() |
Constructor and Description |
---|
MapKeyLoader(String mapName,
OperationService opService,
IPartitionService ps,
ClusterService clusterService,
ExecutionService execService,
IFunction<Object,Data> serialize) |
Modifier and Type | Method and Description |
---|---|
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<ReadResultSet<E>> |
RingbufferProxy.readManyAsync(long startSequence,
int minCount,
int maxCount,
IFunction<E,Boolean> filter) |
Constructor and Description |
---|
ReadResultSetImpl(int minSize,
int maxSize,
HazelcastInstance hz,
IFunction<Object,Boolean> filter) |
Constructor and Description |
---|
ReadManyOperation(String name,
long startSequence,
int minSize,
int maxSize,
IFunction<?,Boolean> filter) |
ReadManyOperation(String name,
long startSequence,
int minSize,
int maxSize,
IFunction<?,Boolean> filter,
boolean returnPortable) |
Modifier and Type | Method and Description |
---|---|
V |
ConcurrentReferenceHashMap.applyIfAbsent(K key,
IFunction<? super K,? extends V> mappingFunction) |
V |
IConcurrentMap.applyIfAbsent(K key,
IFunction<? super K,? extends V> mappingFunction) |
static <T,R> Iterable<R> |
IterableUtil.map(Iterable<T> iterable,
IFunction<T,R> mapper)
Transform the Iterable by applying a function to each element
|
static <T,R> Iterator<R> |
IterableUtil.map(Iterator<T> iterator,
IFunction<T,R> mapper)
Transform the Iterator by applying a function to each element
|
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.