See: Description
Interface | Description |
---|---|
DistributedCollector<T,A,R> |
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<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. |
IStreamCache<K,V> |
A decorator for
ICache for supporting distributed Stream
implementation. |
IStreamList<E> |
A decorator for
IList for supporting distributed Stream
implementation. |
IStreamMap<K,V> |
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 | Description |
---|---|
DistributedCollectors |
Implementations of
DistributedCollector that implement various
useful reduction operations, such as accumulating elements into
collections, summarizing elements according to various criteria, etc. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.