See: Description
| Interface | Description |
|---|---|
| DistributedCollector<T,A,R> |
Serializable variant of java.util.stream.Collector. |
| DistributedCollector.Reducer<T,R> |
Interface for Jet-specific distributed reducers which execute the
terminal reduce operation over the current
DistributedStream
by building and executing a DAG. |
| DistributedDoubleStream |
An extension of
DoubleStream that supports
distributed stream operations by replacing functional interfaces with
their serializable equivalents. |
| DistributedIntStream |
An extension of
IntStream that supports distributed stream
operations by replacing functional interfaces with their serializable
equivalents. |
| DistributedLongStream |
An extension of
LongStream that supports distributed stream
operations by replacing functional interfaces with their serializable
equivalents. |
| DistributedStream<T> |
An extension of
Stream that supports distributed stream
operations by replacing functional interfaces with their Serializable equivalents. |
| Class | Description |
|---|---|
| DistributedCollectors |
Serializable variants of java.util.stream.Collectors. |
| DistributedStream.Cache |
Wrapper class that avoids the runtime dependency of
DistributedStream on javax.cache. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.