Package org.infinispan.stream.impl

Interface Summary

Interface	Description
ClusterStreamManager<Original,K>	Manages distribution of various stream operations that are sent to remote nodes.
ClusterStreamManager.RemoteIteratorPublisher<K>
ClusterStreamManager.ResultsCallback<R>	A callback that is used for result processing from the remote nodes.
IteratorHandler.OnCloseIterator<E>	A CloseableIterator that also allows callers to attach Runnable instances to it, so that when this iterator is closed, those Runnables are also invoked.
IteratorResponse<V>	Iterator response returned when an iterator batch is sent back which contains the iterator, if any segments were suspected and if the iterator has returned all values (complete).
KeyTrackingTerminalOperation<Original,K,R>	A terminal operation for a CacheStream that allows tracking keys during a rehash event.
KeyTrackingTerminalOperation.IntermediateCollector<C>	Collector used to collect items from intermediate responses of operations
LocalStreamManager<Original,K>	Stream manager that is invoked on a local node.
SegmentAwareOperation	Terminal 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.

Class Summary

Class	Description
AbstractCacheStream<Original,T,S extends BaseStream<T,S>,S2 extends S>	Abstract stream that provides all of the common functionality required for all types of Streams including the various primitive types.
AbstractCacheStream.MapOpsExternalizer
AbstractRehashPublisherDecorator<S>	Abstract publisher decorator that is used to notify segment listener of loss of segments while entries are being retrieved.
ClusterStreamManagerImpl<Original,K>	Cluster stream manager that sends all requests using the RpcManager to do the underlying communications.
CompletionRehashPublisherDecorator<S>	PublisherDecorator that only notifies a user listener of segment completion after the last entry for a given segment has been retrieved from iteration.
DistributedCacheStream<Original,R>	Implementation of CacheStream that provides support for lazily distributing stream methods to appropriate nodes
DistributedDoubleCacheStream<Original>	Implementation of DoubleStream that utilizes a lazily evaluated distributed back end execution.
DistributedIntCacheStream<Original>	Implementation of IntStream that utilizes a lazily evaluated distributed back end execution.
DistributedLongCacheStream<Original>	Implementation of LongStream that utilizes a lazily evaluated distributed back end execution.
EndIterator	Singleton object with no state that is used to signal that an iterator has reached the end.
EndIterator.EndIteratorExternalizer
IntermediateCacheStream<Original,R>	An intermediate cache stream used when an intermediate operation that requires both a remote and local portion
IntermediateDoubleCacheStream	An intermediate double cache stream used when an intermediate operation that requires both a remote and local portion
IntermediateIntCacheStream	An intermediate int cache stream used when an intermediate operation that requires both a remote and local portion
IntermediateLongCacheStream	An intermediate long cache stream used when an intermediate operation that requires both a remote and local portion
IteratorHandler	Handler for storing iterators between invocations so that remote node can request data in chunks.
IteratorResponses	Response object used when an iterator is the response value and it is unknown if the iterator has enough entries for the given batch size.
IteratorResponses.IteratorResponsesExternalizer	This externalizer is a special breed that converts a given response into others, based on whether or not an iterator has completed or not.
LocalStreamManagerImpl<Original,K,V>	Local stream manager implementation that handles injection of the stream supplier, invoking the operation and subsequently notifying the operation if a rehash has changed one of its segments.
LockedStreamImpl<K,V>	Lock Stream implementation that locks a key using the LockManager before and after executing the various code.
PartitionAwareClusterStreamManager<Original,K>	Cluster stream manager that also pays attention to partition status and properly closes iterators and throws exceptions when the availability mode changes.
PriorityMergingProcessor<T>	An iterable that will automatically poll entries from the given publishers.
PriorityMergingProcessor.Builder<T>
RemovableCloseableIterator<K,C>	Deprecated. Users should use RemovableCloseableIterator instead
RemovableIterator<K,C>	Deprecated. Users should use RemovableIterator instead
StreamIteratorCloseCommand	Stream iterator command that unregisters an iterator so it doesn't consume memory unnecessarily
StreamIteratorNextCommand	Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.
StreamIteratorRequestCommand<K>	Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.
StreamRequestCommand<K>	Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.
StreamResponseCommand<R>	Stream response command used to handle returning intermediate or final responses from the remote node
TxLockedStreamImpl<K,V>	Locked Stream that is designed for transactions.

Enum Summary

Enum	Description
IntermediateType	The various intermediate types.
StreamRequestCommand.Type