Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Class and Description |
---|
IStreamList
A decorator for
IList for supporting distributed Stream
implementation. |
IStreamMap
A decorator for
IMap for supporting distributed Stream
implementation. |
JetCacheManager
JetCacheManager is the entry point to access JSR-107 (JCache) caches via JetInstance interface. |
Class and Description |
---|
DistributedCollector
A mutable reduction operation that
accumulates input elements into a mutable result container, optionally transforming
the accumulated result into a final representation after all input elements
have been processed.
|
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. |
IStreamCache
A decorator for
ICache for supporting distributed Stream
implementation. |
IStreamList
A decorator for
IList for supporting distributed Stream
implementation. |
IStreamMap
A decorator for
IMap for supporting distributed Stream
implementation. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.