| 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.
|
TV |
ConverterCollections.ConverterInvocableMap.merge(TK key,
TV value,
Remote.BiFunction<? super TV,? super TV,? extends TV> remappingFunction) |
TV |
ConverterCollections.ConverterNamedCache.merge(TK key,
TV value,
Remote.BiFunction<? super TV,? super TV,? extends TV> remappingFunction) |
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. |