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.