Package | Description |
---|---|
com.tangosol.net |
Contains basic cluster interfaces and factories.
|
com.tangosol.util |
Contains various generic utilities.
|
com.tangosol.util.function |
Contains Functional interfaces allowing remote execution of lambda expressions and method references.
|
com.tangosol.util.stream |
Contains classes to support functional-style operations on remote streams of elements, such as map-reduce transformations on collections.
|
Modifier and Type | Method and Description |
---|---|
default CompletableFuture<V> |
AsyncNamedCache.compute(K key, Remote.BiFunction<? super K,? super V,? extends V> remappingFunction)
Compute a new mapping for the specified key and its current value.
|
default CompletableFuture<V> |
AsyncNamedCache.computeIfPresent(K key, Remote.BiFunction<? super K,? super V,? extends V> remappingFunction)
Compute a new mapping given the key and its current mapped value, if the value for the specified key is present and non-null.
|
default CompletableFuture<V> |
AsyncNamedCache.merge(K key, V value, Remote.BiFunction<? super V,? super V,? extends V> remappingFunction)
If the specified key is not already associated with a value or is associated with null, associates it with the given non-null value.
|
default CompletableFuture<Map<K,Void>> |
AsyncNamedCache.replaceAll(Collection<? extends K> collKeys, Remote.BiFunction<? super K,? super V,? extends V> function)
Replace each entry's value with the result of invoking the given function on that entry until all entries for the specified key set have been processed or the function throws an exception.
|
default CompletableFuture<Map<K,Void>> |
AsyncNamedCache.replaceAll(Filter filter, Remote.BiFunction<? super K,? super V,? extends V> function)
Replace each entry's value with the result of invoking the given function on that entry until all entries selected by the specified filter have been processed or the function throws an exception.
|
default CompletableFuture<Map<K,Void>> |
AsyncNamedCache.replaceAll(Remote.BiFunction<? super K,? super V,? extends V> function)
Replace each entry's value with the result of invoking the given function on that entry until all entries have been processed or the function throws an exception.
|
Modifier and Type | Method and Description |
---|---|
default V |
InvocableMap.compute(K key, Remote.BiFunction<? super K,? super V,? extends V> remappingFunction)
Compute a new mapping for the specified key and its current value.
|
default V |
InvocableMap.computeIfPresent(K key, Remote.BiFunction<? super K,? super V,? extends V> remappingFunction)
Compute a new mapping given the key and its current mapped value, if the value for the specified key is present and non-null.
|
default V |
InvocableMap.merge(K key, V value, Remote.BiFunction<? super V,? super V,? extends V> remappingFunction)
If the specified key is not already associated with a value or is associated with null, associates it with the given non-null value.
|
default void |
InvocableMap.replaceAll(Collection<? extends K> collKeys, Remote.BiFunction<? super K,? super V,? extends V> function)
Replace each entry's value with the result of invoking the given function on that entry until all entries for the specified key set have been processed or the function throws an exception.
|
default void |
InvocableMap.replaceAll(Filter filter, Remote.BiFunction<? super K,? super V,? extends V> function)
Replace each entry's value with the result of invoking the given function on that entry until all entries selected by the specified filter have been processed or the function throws an exception.
|
default void |
InvocableMap.replaceAll(Remote.BiFunction<? super K,? super V,? extends V> function)
Replace each entry's value with the result of invoking the given function on that entry until all entries have been processed or the function throws an exception.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
Remote.BinaryOperator<T>
Represents an operation upon two operands of the same type, producing a result of the same type as the operands.
|
Modifier and Type | Method and Description |
---|---|
default <V> Remote.BiFunction<T,U,V> |
Remote.BiFunction.andThen(Remote.Function<? super R,? extends V> after)
Returns a composed function that first applies this function to its input, and then applies the
after function to the result. |
static <T,U,R> Remote.BiFunction<T,U,R> |
Remote.biFunction(Remote.BiFunction<T,U,R> biFunction)
Capture serializable BiFunction.
|
Modifier and Type | Method and Description |
---|---|
static <T,U,R> Remote.BiFunction<T,U,R> |
Remote.biFunction(Remote.BiFunction<T,U,R> biFunction)
Capture serializable BiFunction.
|
Modifier and Type | Method and Description |
---|---|
default <U> U |
RemoteStream.reduce(U identity, Remote.BiFunction<U,? super T,U> accumulator, Remote.BinaryOperator<U> combiner)
Performs a reduction on the elements of this stream, using the provided identity, accumulation and combining functions.
|
static <T,U> RemoteCollector<T,?,U> |
RemoteCollectors.reducing(U identity, Remote.BiFunction<? super U,? super T,? extends U> mapper, Remote.BinaryOperator<U> op)
Returns a
Collector which performs a reduction of its input elements under a specified mapping function and BinaryOperator . |