Package | Description |
---|---|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Class and Description |
---|
DistributedCollector
Serializable variant of java.util.stream.Collector . |
DistributedCollector.Reducer
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
An extension of
Stream that supports distributed stream
operations by replacing functional interfaces with their Serializable equivalents. |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.