Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.functional |
Functional API package
|
org.infinispan.manager |
Cache manager API.
|
org.infinispan.stream.impl.intops.object |
Modifier and Type | Method and Description |
---|---|
default V |
Cache.computeIfAbsent(K key,
SerializableFunction<? super K,? extends V> mappingFunction)
Overloaded
Cache.computeIfAbsent(Object, Function) with Infinispan SerializableFunction . |
default V |
Cache.computeIfAbsent(K key,
SerializableFunction<? super K,? extends V> mappingFunction,
long lifespan,
TimeUnit lifespanUnit)
Overloaded
BasicCache.computeIfAbsent(Object, Function, long, TimeUnit) with Infinispan SerializableFunction . |
default V |
Cache.computeIfAbsent(K key,
SerializableFunction<? super K,? extends V> mappingFunction,
long lifespan,
TimeUnit lifespanUnit,
long maxIdleTime,
TimeUnit maxIdleTimeUnit)
Overloaded
BasicCache.computeIfAbsent(Object, Function, long, TimeUnit, long, TimeUnit) with Infinispan SerializableFunction . |
default V |
AdvancedCache.computeIfAbsent(K key,
SerializableFunction<? super K,? extends V> mappingFunction,
Metadata metadata)
|
default CompletableFuture<V> |
Cache.computeIfAbsentAsync(K key,
SerializableFunction<? super K,? extends V> mappingFunction)
Overloaded
AsyncCache.computeIfAbsentAsync(Object, Function) with Infinispan SerializableFunction . |
default CompletableFuture<V> |
Cache.computeIfAbsentAsync(K key,
SerializableFunction<? super K,? extends V> mappingFunction,
long lifespan,
TimeUnit lifespanUnit)
Overloaded
AsyncCache.computeIfAbsentAsync(Object, Function, long, TimeUnit) with Infinispan SerializableFunction . |
default CompletableFuture<V> |
Cache.computeIfAbsentAsync(K key,
SerializableFunction<? super K,? extends V> mappingFunction,
long lifespan,
TimeUnit lifespanUnit,
long maxIdleTime,
TimeUnit maxIdleTimeUnit)
Overloaded
AsyncCache.computeIfAbsentAsync(Object, Function, long, TimeUnit, long, TimeUnit) with Infinispan SerializableFunction . |
default CompletableFuture<V> |
AdvancedCache.computeIfAbsentAsync(K key,
SerializableFunction<? super K,? extends V> mappingFunction,
Metadata metadata)
|
default <R1> CacheStream<R1> |
CacheStream.flatMap(SerializableFunction<? super R,? extends Stream<? extends R1>> mapper)
Same as
CacheStream.flatMap(Function) except that the Function must also
implement Serializable |
default DoubleCacheStream |
CacheStream.flatMapToDouble(SerializableFunction<? super R,? extends DoubleStream> mapper)
Same as
CacheStream.flatMapToDouble(Function) except that the Function must also
implement Serializable |
default IntCacheStream |
CacheStream.flatMapToInt(SerializableFunction<? super R,? extends IntStream> mapper)
Same as
CacheStream.flatMapToInt(Function) except that the Function must also
implement Serializable |
default LongCacheStream |
CacheStream.flatMapToLong(SerializableFunction<? super R,? extends LongStream> mapper)
Same as
CacheStream.flatMapToLong(Function) except that the Function must also
implement Serializable |
default <R1> CacheStream<R1> |
CacheStream.map(SerializableFunction<? super R,? extends R1> mapper)
Same as
CacheStream.map(Function) except that the Function must also
implement Serializable |
Modifier and Type | Method and Description |
---|---|
default <R> CompletableFuture<R> |
FunctionalMap.ReadOnlyMap.eval(K key,
SerializableFunction<EntryView.ReadEntryView<K,V>,R> f)
Same as
FunctionalMap.ReadOnlyMap.eval(Object, Function) except that the function must also
implement Serializable |
default <R> CompletableFuture<R> |
FunctionalMap.ReadWriteMap.eval(K key,
SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same as
FunctionalMap.ReadWriteMap.eval(Object, Function) except that the function must also
implement Serializable |
default <R> Traversable<R> |
FunctionalMap.ReadWriteMap.evalAll(SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same as
FunctionalMap.ReadWriteMap.evalAll(Function) except that the function must also
implement Serializable |
default <R> Traversable<R> |
FunctionalMap.ReadOnlyMap.evalMany(Set<? extends K> keys,
SerializableFunction<EntryView.ReadEntryView<K,V>,R> f)
Same as
FunctionalMap.ReadOnlyMap.evalMany(Set, Function) except that the function must also
implement Serializable |
default <R> Traversable<R> |
FunctionalMap.ReadWriteMap.evalMany(Set<? extends K> keys,
SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same as
FunctionalMap.ReadWriteMap.evalMany(Set, Function) except that the function must also
implement Serializable |
Modifier and Type | Method and Description |
---|---|
default <V> CompletableFuture<Void> |
ClusterExecutor.submitConsumer(SerializableFunction<? super EmbeddedCacheManager,? extends V> callable,
TriConsumer<? super Address,? super V,? super Throwable> triConsumer)
The same as
ClusterExecutor.submitConsumer(Function, TriConsumer) , except the Callable must also implement
Serializable. |
Constructor and Description |
---|
MapOperation(SerializableFunction<? super I,? extends O> function) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.