Package org.infinispan.stream.impl
package org.infinispan.stream.impl
-
ClassDescriptionAbstract stream that provides all of the common functionality required for all types of Streams including the various primitive types.WARNING: Generated code!WARNING: Generated code!WARNING: Generated code!WARNING: Generated code!Function that is used to encapsulate multiple intermediate operations and perform them lazily when the function is applied.WARNING: Generated code!WARNING: Generated code!WARNING: Generated code!Reducer implementation for Distributed Publisher that converts between CacheStream operations to an appropriate ReducerWARNING: Generated code!DistributedCacheStream<Original,
R> Implementation ofCacheStream
that provides support for lazily distributing stream methods to appropriate nodesDistributedDoubleCacheStream<Original>Implementation ofDoubleStream
that utilizes a lazily evaluated distributed back end execution.DistributedIntCacheStream<Original>Implementation ofIntStream
that utilizes a lazily evaluated distributed back end execution.DistributedLongCacheStream<Original>Implementation ofLongStream
that utilizes a lazily evaluated distributed back end execution.IntermediateCacheStream<Original,R> An intermediate cache stream used when an intermediate operation that requires both a remote and local portionAn intermediate double cache stream used when an intermediate operation that requires both a remote and local portionAn intermediate int cache stream used when an intermediate operation that requires both a remote and local portionAn intermediate long cache stream used when an intermediate operation that requires both a remote and local portionThe various intermediate types.LockedStreamImpl<K,V> Lock Stream implementation that locks a key using theLockManager
before and after executing the various code.Deprecated.RemovableIterator<K,C> Deprecated.Users should useRemovableIterator
insteadTerminal stream operation that is aware of segments being lost.TerminalOperation<Original,R> Interface describing an operation that is a terminal one that doesn't track keys.TxLockedStreamImpl<K,V> Locked Stream that is designed for transactions.
RemovableCloseableIterator
instead