Uses of Package
org.infinispan.stream.impl
-
Packages that use org.infinispan.stream.impl Package Description org.infinispan.commands Commands that operate on the cache, either locally or remotely.org.infinispan.stream.impl org.infinispan.stream.impl.termop org.infinispan.stream.impl.termop.object org.infinispan.stream.impl.termop.primitive org.infinispan.stream.impl.tx -
Classes in org.infinispan.stream.impl used by org.infinispan.commands Class Description StreamIteratorCloseCommand Stream iterator command that unregisters an iterator so it doesn't consume memory unnecessarilyStreamIteratorNextCommand Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.StreamIteratorRequestCommand Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.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 -
Classes in org.infinispan.stream.impl used by org.infinispan.stream.impl Class Description AbstractCacheStream Abstract stream that provides all of the common functionality required for all types of Streams including the various primitive types.AbstractRehashPublisherDecorator Abstract publisher decorator that is used to notify segment listener of loss of segments while entries are being retrieved.ClusterStreamManager Manages distribution of various stream operations that are sent to remote nodes.ClusterStreamManager.RemoteIteratorPublisher ClusterStreamManager.ResultsCallback A callback that is used for result processing from the remote nodes.ClusterStreamManagerImpl Cluster stream manager that sends all requests using theRpcManager
to do the underlying communications.DistributedCacheStream Implementation ofCacheStream
that provides support for lazily distributing stream methods to appropriate nodesDistributedDoubleCacheStream Implementation ofDoubleStream
that utilizes a lazily evaluated distributed back end execution.DistributedIntCacheStream Implementation ofIntStream
that utilizes a lazily evaluated distributed back end execution.DistributedLongCacheStream Implementation ofLongStream
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.IntermediateType The various intermediate types.IteratorHandler Handler for storing iterators between invocations so that remote node can request data in chunks.IteratorHandler.OnCloseIterator ACloseableIterator
that also allows callers to attachRunnable
instances to it, so that when this iterator is closed, those Runnables are also invoked.IteratorResponse 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).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.KeyTrackingTerminalOperation A terminal operation for aCacheStream
that allows tracking keys during a rehash event.KeyTrackingTerminalOperation.IntermediateCollector Collector used to collect items from intermediate responses of operationsLocalStreamManager Stream manager that is invoked on a local node.LockedStreamImpl Lock Stream implementation that locks a key using theLockManager
before and after executing the various code.PriorityMergingProcessor An iterable that will automatically poll entries from the given publishers.PriorityMergingProcessor.Builder SegmentAwareOperation Terminal stream operation that is aware of segments being lost.StreamIteratorNextCommand Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.StreamRequestCommand.Type TerminalOperation Interface describing an operation that is a terminal one that doesn't track keys. -
Classes in org.infinispan.stream.impl used by org.infinispan.stream.impl.termop Class Description KeyTrackingTerminalOperation A terminal operation for aCacheStream
that allows tracking keys during a rehash event.KeyTrackingTerminalOperation.IntermediateCollector Collector used to collect items from intermediate responses of operationsSegmentAwareOperation 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. -
Classes in org.infinispan.stream.impl used by org.infinispan.stream.impl.termop.object Class Description KeyTrackingTerminalOperation A terminal operation for aCacheStream
that allows tracking keys during a rehash event.SegmentAwareOperation Terminal stream operation that is aware of segments being lost. -
Classes in org.infinispan.stream.impl used by org.infinispan.stream.impl.termop.primitive Class Description KeyTrackingTerminalOperation A terminal operation for aCacheStream
that allows tracking keys during a rehash event.KeyTrackingTerminalOperation.IntermediateCollector Collector used to collect items from intermediate responses of operationsSegmentAwareOperation Terminal stream operation that is aware of segments being lost. -
Classes in org.infinispan.stream.impl used by org.infinispan.stream.impl.tx Class 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.RemoteIteratorPublisher ClusterStreamManager.ResultsCallback A callback that is used for result processing from the remote nodes.DistributedCacheStream Implementation ofCacheStream
that provides support for lazily distributing stream methods to appropriate nodesDistributedDoubleCacheStream Implementation ofDoubleStream
that utilizes a lazily evaluated distributed back end execution.DistributedIntCacheStream Implementation ofIntStream
that utilizes a lazily evaluated distributed back end execution.DistributedLongCacheStream Implementation ofLongStream
that utilizes a lazily evaluated distributed back end execution.KeyTrackingTerminalOperation A terminal operation for aCacheStream
that allows tracking keys during a rehash event.TerminalOperation Interface describing an operation that is a terminal one that doesn't track keys.