Class Hierarchy
- java.lang.Object
- org.infinispan.stream.impl.AbstractCacheStream<Original,T,S,S2> (implements java.util.stream.BaseStream<T,S>)
- org.infinispan.stream.impl.DistributedCacheStream<Original,R> (implements org.infinispan.CacheStream<R>)
- org.infinispan.stream.impl.DistributedDoubleCacheStream<Original> (implements org.infinispan.DoubleCacheStream)
- org.infinispan.stream.impl.DistributedIntCacheStream<Original> (implements org.infinispan.IntCacheStream)
- org.infinispan.stream.impl.DistributedLongCacheStream<Original> (implements org.infinispan.LongCacheStream)
- org.infinispan.commons.marshall.AbstractExternalizer<T> (implements org.infinispan.commons.marshall.AdvancedExternalizer<T>)
- org.infinispan.stream.impl.AbstractCacheStream.MapOpsExternalizer
- org.infinispan.stream.impl.EndIterator.EndIteratorExternalizer
- org.infinispan.stream.impl.IteratorResponses.IteratorResponsesExternalizer
- org.infinispan.stream.impl.AbstractRehashPublisherDecorator<S>
- org.infinispan.stream.impl.CompletionRehashPublisherDecorator<S>
- org.infinispan.commands.remote.BaseRpcCommand (implements org.infinispan.commands.remote.CacheRpcCommand)
- org.infinispan.stream.impl.StreamIteratorCloseCommand
- org.infinispan.stream.impl.StreamIteratorNextCommand (implements org.infinispan.commands.TopologyAffectedCommand)
- org.infinispan.stream.impl.StreamIteratorRequestCommand<K>
- org.infinispan.stream.impl.StreamRequestCommand<K> (implements org.infinispan.commands.TopologyAffectedCommand)
- org.infinispan.stream.impl.StreamResponseCommand<R>
- org.infinispan.stream.impl.ClusterStreamManagerImpl<Original,K> (implements org.infinispan.stream.impl.ClusterStreamManager<Original,K>)
- org.infinispan.stream.impl.PartitionAwareClusterStreamManager<Original,K>
- org.infinispan.stream.impl.EndIterator
- org.infinispan.stream.impl.IntermediateCacheStream<Original,R> (implements org.infinispan.CacheStream<R>)
- org.infinispan.stream.impl.IntermediateDoubleCacheStream (implements org.infinispan.DoubleCacheStream)
- org.infinispan.stream.impl.IntermediateIntCacheStream (implements org.infinispan.IntCacheStream)
- org.infinispan.stream.impl.IntermediateLongCacheStream (implements org.infinispan.LongCacheStream)
- org.infinispan.stream.impl.IteratorHandler
- org.infinispan.stream.impl.IteratorResponses (implements org.infinispan.stream.impl.IteratorResponse<V>)
- org.infinispan.stream.impl.LocalStreamManagerImpl<Original,K,V> (implements org.infinispan.stream.impl.LocalStreamManager<Original,K>)
- org.infinispan.stream.impl.LockedStreamImpl<K,V> (implements org.infinispan.LockedStream<K,V>)
- org.infinispan.stream.impl.TxLockedStreamImpl<K,V>
- org.infinispan.stream.impl.PriorityMergingProcessor<T> (implements org.infinispan.commons.util.CloseableIterable<E>)
- org.infinispan.stream.impl.PriorityMergingProcessor.Builder<T>
- org.infinispan.commons.util.RemovableIterator<C> (implements java.util.Iterator<E>)
- org.infinispan.commons.util.RemovableCloseableIterator<C> (implements org.infinispan.commons.util.CloseableIterator<E>)
- org.infinispan.stream.impl.RemovableCloseableIterator<K,C>
- org.infinispan.stream.impl.RemovableIterator<K,C>
- org.infinispan.commons.util.RemovableCloseableIterator<C> (implements org.infinispan.commons.util.CloseableIterator<E>)
- org.infinispan.stream.impl.AbstractCacheStream<Original,T,S,S2> (implements java.util.stream.BaseStream<T,S>)
Interface Hierarchy
- java.lang.AutoCloseable
- org.infinispan.commons.util.CloseableIterator<E> (also extends java.util.Iterator<E>)
- org.infinispan.stream.impl.IteratorHandler.OnCloseIterator<E>
- org.infinispan.commons.util.CloseableIterator<E> (also extends java.util.Iterator<E>)
- org.infinispan.stream.impl.ClusterStreamManager<Original,K>
- org.infinispan.stream.impl.ClusterStreamManager.ResultsCallback<R>
- java.util.Iterator<E>
- org.infinispan.commons.util.CloseableIterator<E> (also extends java.lang.AutoCloseable)
- org.infinispan.stream.impl.IteratorHandler.OnCloseIterator<E>
- org.infinispan.commons.util.CloseableIterator<E> (also extends java.lang.AutoCloseable)
- org.infinispan.stream.impl.IteratorResponse<V>
- org.infinispan.stream.impl.KeyTrackingTerminalOperation.IntermediateCollector<C>
- org.infinispan.stream.impl.LocalStreamManager<Original,K>
- org.reactivestreams.Publisher<T>
- org.infinispan.stream.impl.ClusterStreamManager.RemoteIteratorPublisher<K>
- org.infinispan.stream.impl.SegmentAwareOperation
- org.infinispan.stream.impl.KeyTrackingTerminalOperation<Original,K,R>
- org.infinispan.stream.impl.TerminalOperation<Original,R>
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.infinispan.stream.impl.IntermediateType
- org.infinispan.stream.impl.StreamRequestCommand.Type
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)