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.
|
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. |