Package org.infinispan.stream.impl

Interface Summary

Interface	Description
ClusterStreamManager<K>	Manages distribution of various stream operations that are sent to remote nodes.
ClusterStreamManager.ResultsCallback<R>	A callback that is used for result processing from the remote nodes.
KeyTrackingTerminalOperation<K,R,R2>	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<K>	Stream manager that is invoked on a local node.
SegmentAwareOperation	Terminal stream operation that is aware of segments being lost.
TerminalOperation<R>	Interface describing an operation that is a terminal one that doesn't track keys.

Class Summary

Class	Description
AbstractCacheStream<T,S extends BaseStream<T,S>,T_CONS>	Abstract stream that provides all of the common functionality required for all types of Streams including the various primitive types.
AbstractDelegatingCacheCollection<E>
AbstractDelegatingCacheSet<E>	Same as AbstractDelegatingCacheCollection except this method implements Set as well.
AbstractDelegatingCacheStream<R>	Delegate that forwards all the of the method calls to the underlying cache stream.
ClusterStreamManagerImpl<K>	Cluster stream manager that sends all requests using the RpcManager to do the underlying communications.
DistributedCacheStream<R>	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.
LocalStreamManagerImpl<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.
PartitionAwareClusterStreamManager<K>	Cluster stream manager that also pays attention to partition status and properly closes iterators and throws exceptions when the availability mode changes.
RemovableCloseableIterator<K,C>	A CloseableIterator implementation that allows for a CloseableIterator that doesn't allow remove operations to implement remove by delegating the call to the provided cache to remove the previously read value.
RemovableIterator<K,C>	An Iterator implementation that allows for a Iterator that doesn't allow remove operations to implement remove by delegating the call to the provided cache to remove the previously read value.
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
StreamSegmentResponseCommand<R>	A stream response command taht also returns back suspected segments that need to be retried

Enum Summary

Enum	Description
StreamRequestCommand.Type