| Package | Description |
|---|---|
| com.tangosol.util.function |
Contains Functional interfaces allowing remote execution of lambda expressions and method references.
|
| com.tangosol.util.processor |
Contains concrete
InvocableMap.EntryProcessor
implementations. |
| 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 |
|---|---|
static <T> Remote.Supplier<T> |
Remote.supplier(Remote.Supplier<T> supplier)
Capture serializable Supplier.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> Remote.Supplier<T> |
Remote.supplier(Remote.Supplier<T> supplier)
Capture serializable Supplier.
|
| Modifier and Type | Field and Description |
|---|---|
protected Remote.Supplier<V> |
MethodInvocationProcessor.m_supplier
The supplier that should be used to create the entry value if this
processor is invoked on an entry that is not present in the cache.
|
| Modifier and Type | Method and Description |
|---|---|
Remote.Supplier<V> |
MethodInvocationProcessor.getSupplier()
Returns the supplier that should be used when an entry is not present.
|
| Constructor and Description |
|---|
MethodInvocationProcessor(Remote.Supplier<V> supplier,
String sMethodName,
boolean fMutator,
Object... aoArgs)
Construct MethodInvocationProcessor instance.
|
| Modifier and Type | Method and Description |
|---|---|
default <R> R |
RemoteStream.collect(Remote.Supplier<R> supplier,
Remote.BiConsumer<R,? super T> accumulator,
Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this stream.
|
default <R> R |
RemoteDoubleStream.collect(Remote.Supplier<R> supplier,
Remote.ObjDoubleConsumer<R> accumulator,
Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this
stream.
|
default <R> R |
RemoteIntStream.collect(Remote.Supplier<R> supplier,
Remote.ObjIntConsumer<R> accumulator,
Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this
stream.
|
default <R> R |
RemoteLongStream.collect(Remote.Supplier<R> supplier,
Remote.ObjLongConsumer<R> accumulator,
Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this
stream.
|
static <T,U,K,D,A,M extends Map<K,D>> |
RemoteCollectors.groupingBy(ValueExtractor<? super U,? extends K> extractor,
Remote.Supplier<M> mapFactory,
RemoteCollector<? super T,A,D> downstream)
Returns a
Collector implementing a cascaded "group by" operation
on input elements of type T, grouping elements according to a
classification function, and then performing a reduction operation on the
values associated with a given key using the specified downstream Collector. |
static <T,A,R> RemoteCollector<T,A,R> |
RemoteCollector.of(Remote.Supplier<A> supplier,
Remote.BiConsumer<A,T> accumulator,
Remote.BinaryOperator<A> combiner,
Remote.Function<A,R> finisher,
Collector.Characteristics... characteristics)
Returns a new
Collector described by the given supplier,
accumulator, combiner, and finisher functions. |
static <T,R> RemoteCollector<T,R,R> |
RemoteCollector.of(Remote.Supplier<R> supplier,
Remote.BiConsumer<R,T> accumulator,
Remote.BinaryOperator<R> combiner,
Collector.Characteristics... characteristics)
Returns a new
Collector described by the given supplier,
accumulator, and combiner functions. |
static <T,C extends Collection<T>> |
RemoteCollectors.toCollection(Remote.Supplier<C> supplier)
Returns a
Collector that accumulates the input elements into a
new Collection, in encounter order. |
static <T,U1,U2,K,V,M extends Map<K,V>> |
RemoteCollectors.toMap(ValueExtractor<? super U1,? extends K> keyExtractor,
ValueExtractor<? super U2,? extends V> valueExtractor,
Remote.BinaryOperator<V> mergeFunction,
Remote.Supplier<M> mapSupplier)
Returns a
Collector that accumulates elements into a Map
whose keys and values are the result of applying the provided mapping
functions to the input elements. |