Interface FunctionalMap.ReadWriteMap<K,V>
-
- All Superinterfaces:
AutoCloseable
,FunctionalMap<K,V>
- Enclosing interface:
- FunctionalMap<K,V>
@Experimental public static interface FunctionalMap.ReadWriteMap<K,V> extends FunctionalMap<K,V>
Exposes read-write operations that can be executed against the functional map. The read-write operations that can be applied per entry are exposed byEntryView.ReadWriteEntryView
.Read-write operations offer the possibility of writing values or metadata parameters, and returning previously stored information. Read-write operations are also crucial for implementing conditional, compare-and-swap (CAS) like operations.
Locks are acquired before executing the read-write lambda.
Method parameters for read-write operations, including lambdas, must be marshallable when running in a cluster.
- Since:
- 8.0
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.infinispan.functional.FunctionalMap
FunctionalMap.ReadOnlyMap<K,V>, FunctionalMap.ReadWriteMap<K,V>, FunctionalMap.WriteOnlyMap<K,V>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description <R> CompletableFuture<R>
eval(K key, Function<EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-write function on the value and metadata associated with the key and return aCompletableFuture
with the return type of the function.default <R> CompletableFuture<R>
eval(K key, org.infinispan.util.function.SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same aseval(Object, Function)
except that the function must also implementSerializable
<T,R>
CompletableFuture<R>eval(K key, T argument, BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-write function, with an argument passed in and aEntryView.WriteEntryView
of the value associated with the key, and return aCompletableFuture
which will be completed with the returned value by the function.default <T,R>
CompletableFuture<R>eval(K key, T argument, org.infinispan.util.function.SerializableBiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f)
Same aseval(Object, Object, BiFunction)
except that the function must also implementSerializable
<R> Traversable<R>
evalAll(Function<EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-writeFunction
operation with theEntryView.ReadWriteEntryView
of the value associated with the key, for all existing keys, and returns aTraversable
to navigate each of theFunction
invocation returns.default <R> Traversable<R>
evalAll(org.infinispan.util.function.SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same asevalAll(Function)
except that the function must also implementSerializable
<T,R>
Traversable<R>evalMany(Map<? extends K,? extends T> arguments, BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-writeBiFunction
, with an argument passed in and aEntryView.ReadWriteEntryView
of the value associated with the key, for each of the keys in the set passed in, and returns anTraversable
to navigate each of theBiFunction
invocation returns.default <T,R>
Traversable<R>evalMany(Map<? extends K,? extends T> arguments, org.infinispan.util.function.SerializableBiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f)
Same asevalMany(Map, BiFunction)
except that the function must also implementSerializable
<R> Traversable<R>
evalMany(Set<? extends K> keys, Function<EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-writeFunction
operation with theEntryView.ReadWriteEntryView
of the value associated with the key, for each of the keys in the set passed in, and returns aTraversable
to navigate each of theFunction
invocation returns.default <R> Traversable<R>
evalMany(Set<? extends K> keys, org.infinispan.util.function.SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same asevalMany(Set, Function)
except that the function must also implementSerializable
Listeners.ReadWriteListeners<K,V>
listeners()
Allows to read-write listeners to be registered.FunctionalMap.ReadWriteMap<K,V>
withParams(Param<?>... ps)
Tweak read-write functional map executions providingParam
instances.-
Methods inherited from interface org.infinispan.functional.FunctionalMap
getName, getStatus, isEncoded
-
-
-
-
Method Detail
-
withParams
FunctionalMap.ReadWriteMap<K,V> withParams(Param<?>... ps)
Tweak read-write functional map executions providingParam
instances.- Specified by:
withParams
in interfaceFunctionalMap<K,V>
-
eval
<R> CompletableFuture<R> eval(K key, Function<EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-write function on the value and metadata associated with the key and return aCompletableFuture
with the return type of the function. If the user is not sure if the key is present,EntryView.ReadEntryView.find()
can be used to find out for sure. This method can be used to implement single-key read-write operations inConcurrentMap
andjavax.cache.Cache
that do not depend on value information given by the user such as:Map.remove(Object)
javax.cache.Cache#remove(Object)
javax.cache.Cache#getAndRemove(Object)
javax.cache.Cache#invoke(Object, EntryProcessor, Object...)
The function must not mutate neither the key returned through
EntryView.ReadEntryView.key()
nor the internally stored value provided throughEntryView.ReadEntryView.get()
orEntryView.ReadEntryView.find()
.- Type Parameters:
R
- function return type- Parameters:
key
- the key associated with theEntryView.ReadWriteEntryView
to be passed to the function.f
- function that takes aEntryView.ReadWriteEntryView
associated with the key, and returns a value.- Returns:
- a
CompletableFuture
which will be completed with the returned value from the function
-
eval
default <R> CompletableFuture<R> eval(K key, org.infinispan.util.function.SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same aseval(Object, Function)
except that the function must also implementSerializable
The compiler will pick this overload for lambda parameters, making them
Serializable
-
eval
<T,R> CompletableFuture<R> eval(K key, T argument, BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-write function, with an argument passed in and aEntryView.WriteEntryView
of the value associated with the key, and return aCompletableFuture
which will be completed with the returned value by the function.This method provides the the capability to both update the value and metadata associated with that key, and return previous value or metadata.
This method can be used to implement the vast majority of single-key read-write operations in
ConcurrentMap
andjavax.cache.Cache
such as:Map.put(Object, Object)
ConcurrentMap.putIfAbsent(Object, Object)
ConcurrentMap.replace(Object, Object)
ConcurrentMap.replace(Object, Object, Object)
ConcurrentMap.remove(Object, Object)
javax.cache.Cache#getAndPut(Object, Object)
javax.cache.Cache#putIfAbsent(Object, Object)
javax.cache.Cache#remove(Object, Object)
javax.cache.Cache#replace(Object, Object, Object)
javax.cache.Cache#replace(Object, Object)
javax.cache.Cache#getAndReplace(Object, Object)
The functionality provided by this function could indeed be implemented with
eval(Object, Function)
, but there's a crucial difference. If you want to store a value and reference the value to be stored from the passed in operation,eval(Object, Function)
needs to capture that value. Capturing means that each time the operation is called, a new lambda needs to be instantiated. By offering aBiFunction
that takes user provided value as first parameter, the operation does not capture any external objects when implementing simple operations such asjavax.cache.Cache#getAndPut(Object, Object)
, and hence, theBiFunction
could be cached and reused each time it's invoked.Note that when
encoders
are in place despite the argument type and value type don't have to match the argument will use value encoding.The function must not mutate neither the key returned through
EntryView.ReadEntryView.key()
nor the internally stored value provided throughEntryView.ReadEntryView.get()
orEntryView.ReadEntryView.find()
.- Type Parameters:
R
- type of the function's return- Parameters:
key
- the key associated with theEntryView.ReadWriteEntryView
to be passed to the operationargument
- argument passed in as first parameter to theBiFunction
.f
- operation that takes a user defined value, and aEntryView.ReadWriteEntryView
associated with the key, and writes to theEntryView.ReadWriteEntryView
passed in, possibly returning previously stored value or metadata information- Returns:
- a
CompletableFuture
which will be completed with the returned value from the function
-
eval
default <T,R> CompletableFuture<R> eval(K key, T argument, org.infinispan.util.function.SerializableBiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f)
Same aseval(Object, Object, BiFunction)
except that the function must also implementSerializable
The compiler will pick this overload for lambda parameters, making them
Serializable
-
evalMany
<T,R> Traversable<R> evalMany(Map<? extends K,? extends T> arguments, BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-writeBiFunction
, with an argument passed in and aEntryView.ReadWriteEntryView
of the value associated with the key, for each of the keys in the set passed in, and returns anTraversable
to navigate each of theBiFunction
invocation returns.This method can be used to implement operations that store a set of keys and return previous values or metadata parameters.
These kind of operations are preferred to traditional end user iterations because the internal logic can often iterate more efficiently since it knows more about the system.
Note that when
encoders
are in place despite the argument type and value type don't have to match the argument will use value encoding.The function must not mutate neither the key returned through
EntryView.ReadEntryView.key()
nor the internally stored value provided throughEntryView.ReadEntryView.get()
orEntryView.ReadEntryView.find()
.- Parameters:
arguments
- the key/value pairs associated with each of theEntryView.ReadWriteEntryView
passed in the function callbacksf
- function that takes in a value associated with a key in the entries collection and theEntryView.ReadWriteEntryView
associated with that key in the cache- Returns:
- a
Traversable
to navigate eachBiFunction
return
-
evalMany
default <T,R> Traversable<R> evalMany(Map<? extends K,? extends T> arguments, org.infinispan.util.function.SerializableBiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f)
Same asevalMany(Map, BiFunction)
except that the function must also implementSerializable
The compiler will pick this overload for lambda parameters, making them
Serializable
-
evalMany
<R> Traversable<R> evalMany(Set<? extends K> keys, Function<EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-writeFunction
operation with theEntryView.ReadWriteEntryView
of the value associated with the key, for each of the keys in the set passed in, and returns aTraversable
to navigate each of theFunction
invocation returns.This method can be used to implement operations such as
javax.cache.Cache#invokeAll(Set, EntryProcessor, Object...)
, or a remove a set of keys returning previous values or metadata parameters.The function must not mutate neither the key returned through
EntryView.ReadEntryView.key()
nor the internally stored value provided throughEntryView.ReadEntryView.get()
orEntryView.ReadEntryView.find()
.- Parameters:
keys
- the keys associated with each of theEntryView.ReadWriteEntryView
passed in the function callbacksf
- function that theEntryView.ReadWriteEntryView
associated with one of the keys passed in, and returns a value- Returns:
- a
Traversable
to navigate eachFunction
return
-
evalMany
default <R> Traversable<R> evalMany(Set<? extends K> keys, org.infinispan.util.function.SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same asevalMany(Set, Function)
except that the function must also implementSerializable
The compiler will pick this overload for lambda parameters, making them
Serializable
-
evalAll
<R> Traversable<R> evalAll(Function<EntryView.ReadWriteEntryView<K,V>,R> f)
Evaluate a read-writeFunction
operation with theEntryView.ReadWriteEntryView
of the value associated with the key, for all existing keys, and returns aTraversable
to navigate each of theFunction
invocation returns.This method can be used to an operation that removes all cached entries individually, and returns previous value and/or metadata parameters.
The function must not mutate neither the key returned through
EntryView.ReadEntryView.key()
nor the internally stored value provided throughEntryView.ReadEntryView.get()
orEntryView.ReadEntryView.find()
.- Returns:
- a
Traversable
to navigate eachFunction
return
-
evalAll
default <R> Traversable<R> evalAll(org.infinispan.util.function.SerializableFunction<EntryView.ReadWriteEntryView<K,V>,R> f)
Same asevalAll(Function)
except that the function must also implementSerializable
The compiler will pick this overload for lambda parameters, making them
Serializable
-
listeners
Listeners.ReadWriteListeners<K,V> listeners()
Allows to read-write listeners to be registered.
-
-