| Package | Description |
|---|---|
| org.infinispan.stream.impl |
| Class and Description |
|---|
| AbstractCacheStream
Abstract stream that provides all of the common functionality required for all types of Streams including the various
primitive types.
|
| CacheIntermediatePublisher
Function that is used to encapsulate multiple intermediate operations and perform them lazily when the function
is applied.
|
| CacheStreamIntermediateReducer
Reducer implementation for Distributed Publisher that converts between CacheStream operations to an
appropriate Reducer
|
| DistributedCacheStream
Implementation of
CacheStream that provides support for lazily distributing stream methods to appropriate
nodes |
| DistributedDoubleCacheStream
Implementation of
DoubleStream that utilizes a lazily evaluated distributed back end execution. |
| DistributedIntCacheStream
Implementation of
IntStream that utilizes a lazily evaluated distributed back end execution. |
| DistributedLongCacheStream
Implementation of
LongStream that utilizes a lazily evaluated distributed back end execution. |
| IntermediateType
The various intermediate types.
|
| LockedStreamImpl
Lock Stream implementation that locks a key using the
LockManager before and after executing the various
code. |
| SegmentAwareOperation
Terminal stream operation that is aware of segments being lost.
|
Copyright © 2022 JBoss by Red Hat. All rights reserved.