| Package | Description |
|---|---|
| org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
| org.infinispan.interceptors.compat | |
| org.infinispan.stream.impl | |
| org.infinispan.stream.impl.interceptor | |
| org.infinispan.stream.impl.termop | |
| org.infinispan.stream.impl.termop.object | |
| org.infinispan.stream.impl.termop.primitive | |
| org.infinispan.stream.impl.tx |
| Class and Description |
|---|
| ClusterStreamManager
Manages distribution of various stream operations that are sent to remote nodes.
|
| LocalStreamManager
Stream manager that is invoked on a local node.
|
| StreamRequestCommand
Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.
|
| StreamRequestCommand.Type |
| StreamResponseCommand
Stream response command used to handle returning intermediate or final responses from the remote node
|
| Class and Description |
|---|
| AbstractDelegatingCacheStream
Delegate that forwards all the of the method calls to the underlying cache stream.
|
| Class and Description |
|---|
| AbstractCacheStream
Abstract stream that provides all of the common functionality required for all types of Streams including the various
primitive types.
|
| AbstractDelegatingCacheCollection |
| ClusterStreamManager
Manages distribution of various stream operations that are sent to remote nodes.
|
| ClusterStreamManager.ResultsCallback
A callback that is used for result processing from the remote nodes.
|
| ClusterStreamManagerImpl
Cluster stream manager that sends all requests using the
RpcManager to do the underlying communications. |
| 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. |
| KeyTrackingTerminalOperation
A terminal operation for a
CacheStream that allows tracking keys during a rehash event. |
| KeyTrackingTerminalOperation.IntermediateCollector
Collector used to collect items from intermediate responses of operations
|
| LocalStreamManager
Stream manager that is invoked on a local node.
|
| PartitionAwareClusterStreamManager.PartitionListener |
| RemovableIterator
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.
|
| SegmentAwareOperation
Terminal stream operation that is aware of segments being lost.
|
| StreamRequestCommand.Type |
| StreamResponseCommand
Stream response command used to handle returning intermediate or final responses from the remote node
|
| TerminalOperation
Interface describing an operation that is a terminal one that doesn't track keys.
|
| Class and Description |
|---|
| AbstractDelegatingCacheCollection |
| AbstractDelegatingCacheSet
Same as
AbstractDelegatingCacheCollection except this method implements Set as well. |
| Class and Description |
|---|
| KeyTrackingTerminalOperation
A terminal operation for a
CacheStream that allows tracking keys during a rehash event. |
| KeyTrackingTerminalOperation.IntermediateCollector
Collector used to collect items from intermediate responses of operations
|
| SegmentAwareOperation
Terminal stream operation that is aware of segments being lost.
|
| TerminalOperation
Interface describing an operation that is a terminal one that doesn't track keys.
|
| Class and Description |
|---|
| KeyTrackingTerminalOperation
A terminal operation for a
CacheStream that allows tracking keys during a rehash event. |
| KeyTrackingTerminalOperation.IntermediateCollector
Collector used to collect items from intermediate responses of operations
|
| SegmentAwareOperation
Terminal stream operation that is aware of segments being lost.
|
| Class and Description |
|---|
| KeyTrackingTerminalOperation
A terminal operation for a
CacheStream that allows tracking keys during a rehash event. |
| KeyTrackingTerminalOperation.IntermediateCollector
Collector used to collect items from intermediate responses of operations
|
| SegmentAwareOperation
Terminal stream operation that is aware of segments being lost.
|
| Class and Description |
|---|
| AbstractCacheStream
Abstract stream that provides all of the common functionality required for all types of Streams including the various
primitive types.
|
| ClusterStreamManager
Manages distribution of various stream operations that are sent to remote nodes.
|
| ClusterStreamManager.ResultsCallback
A callback that is used for result processing from the remote nodes.
|
| 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. |
| KeyTrackingTerminalOperation
A terminal operation for a
CacheStream that allows tracking keys during a rehash event. |
| TerminalOperation
Interface describing an operation that is a terminal one that doesn't track keys.
|
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.