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 | 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 | Description |
---|---|
StreamRequestCommand.Type |
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.