| Package | Description |
|---|---|
| org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
| org.infinispan.stream |
Cache stream processing.
|
| org.infinispan.stream.impl | |
| org.infinispan.stream.impl.local | |
| org.infinispan.util |
General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and
collections and containers designed to supplement the JDK-provided containers.
|
| Modifier and Type | Method and Description |
|---|---|
default <R1> R1 |
CacheStream.collect(SerializableSupplier<Collector<? super R,?,R1>> supplier)
Performs a mutable
reduction operation on the elements of this stream using a
Collector that is lazily created from the SerializableSupplier
provided. |
default <R> R |
DoubleCacheStream.collect(SerializableSupplier<R> supplier,
SerializableObjDoubleConsumer<R> accumulator,
SerializableBiConsumer<R,R> combiner)
Same as
DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer) except that the arguments must
also implement Serializable |
default <R> R |
IntCacheStream.collect(SerializableSupplier<R> supplier,
SerializableObjIntConsumer<R> accumulator,
SerializableBiConsumer<R,R> combiner)
Same as
IntStream.collect(Supplier, ObjIntConsumer, BiConsumer) except that the arguments must also
implement Serializable |
default <R> R |
LongCacheStream.collect(SerializableSupplier<R> supplier,
SerializableObjLongConsumer<R> accumulator,
SerializableBiConsumer<R,R> combiner)
Same as
LongStream.collect(Supplier, ObjLongConsumer, BiConsumer) except that the arguments must
also implement Serializable. |
default <R1> R1 |
CacheStream.collect(SerializableSupplier<R1> supplier,
SerializableBiConsumer<R1,? super R> accumulator,
SerializableBiConsumer<R1,R1> combiner)
Same as
Stream.collect(Supplier, BiConsumer, BiConsumer) except that the various arguments must
also implement Serializable |
| Modifier and Type | Method and Description |
|---|---|
static <T,R> Collector<T,?,R> |
CacheCollectors.serializableCollector(SerializableSupplier<Collector<T,?,R>> supplier)
Creates a collector that is serializable and will upon usage create a collector using the serializable supplier
provided by the user.
|
| Modifier and Type | Method and Description |
|---|---|
<R1> R1 |
IntermediateCacheStream.collect(SerializableSupplier<Collector<? super R,?,R1>> supplier) |
| Modifier and Type | Method and Description |
|---|---|
<R1> R1 |
LocalCacheStream.collect(SerializableSupplier<Collector<? super R,?,R1>> supplier) |
| Modifier and Type | Method and Description |
|---|---|
static <T,R> SerializableSupplier<Collector<T,?,R>> |
Casting.toSerialSupplierCollect(SerializableSupplier supplier) |
| Modifier and Type | Method and Description |
|---|---|
static <T,R> SerializableSupplier<Collector<T,?,R>> |
Casting.toSerialSupplierCollect(SerializableSupplier supplier) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.