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 © 2021 JBoss, a division of Red Hat. All rights reserved.