Class AbstractCacheStream<Original, T, S extends BaseStream<T,S>, S2 extends S>

java.lang.Object
org.infinispan.stream.impl.AbstractCacheStream<Original,T,S,S2>
Type Parameters:
Original - the original type of the underlying stream - normally CacheEntry or Object
T - The type returned by the stream
S - The stream interface
All Implemented Interfaces:
AutoCloseable, BaseStream<T,S>
Direct Known Subclasses:
DistributedCacheStream, DistributedDoubleCacheStream, DistributedIntCacheStream, DistributedLongCacheStream

public abstract class AbstractCacheStream<Original, T, S extends BaseStream<T,S>, S2 extends S> extends Object implements BaseStream<T,S>
Abstract stream that provides all of the common functionality required for all types of Streams including the various primitive types.
  • Field Details Link icon

    • intermediateOperations Link icon

      protected final Queue<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations
    • localAddress Link icon

      protected final Address localAddress
    • cpm Link icon

      protected final ClusterPublisherManager cpm
    • executor Link icon

      protected final Executor executor
    • registry Link icon

      protected final ComponentRegistry registry
    • partition Link icon

      protected final PartitionHandlingManager partition
    • keyPartitioner Link icon

      protected final KeyPartitioner keyPartitioner
    • stateTransferLock Link icon

      protected final org.infinispan.statetransfer.StateTransferLock stateTransferLock
    • explicitFlags Link icon

      protected final long explicitFlags
    • toKeyFunction Link icon

      protected final Function<? super Original, ?> toKeyFunction
    • invocationContext Link icon

      protected final InvocationContext invocationContext
    • closeRunnable Link icon

      protected Runnable closeRunnable
    • parallelDistribution Link icon

      protected Boolean parallelDistribution
    • parallel Link icon

      protected boolean parallel
    • rehashAware Link icon

      protected boolean rehashAware
    • keysToFilter Link icon

      protected Set<?> keysToFilter
    • segmentsToFilter Link icon

      protected IntSet segmentsToFilter
    • distributedBatchSize Link icon

      protected int distributedBatchSize
    • segmentCompletionListener Link icon

      protected Consumer<Supplier<PrimitiveIterator.OfInt>> segmentCompletionListener
    • iteratorOperation Link icon

      protected org.infinispan.stream.impl.AbstractCacheStream.IteratorOperation iteratorOperation
    • timeout Link icon

      protected long timeout
    • timeoutUnit Link icon

      protected TimeUnit timeoutUnit
  • Constructor Details Link icon

  • Method Details Link icon

    • getLog Link icon

      protected abstract org.infinispan.util.logging.Log getLog()
    • addIntermediateOperation Link icon

      protected S2 addIntermediateOperation(org.infinispan.stream.impl.intops.IntermediateOperation<T,S,T,S> intermediateOperation)
    • addIntermediateOperationMap Link icon

      protected void addIntermediateOperationMap(org.infinispan.stream.impl.intops.IntermediateOperation<T,S,?,?> intermediateOperation)
    • addIntermediateOperation Link icon

      protected void addIntermediateOperation(Queue<org.infinispan.stream.impl.intops.IntermediateOperation> intermediateOperations, org.infinispan.stream.impl.intops.IntermediateOperation<T,S,?,?> intermediateOperation)
    • unwrap Link icon

      protected abstract S2 unwrap()
    • isParallel Link icon

      public boolean isParallel()
      Specified by:
      isParallel in interface BaseStream<Original,T>
    • sequential Link icon

      public S2 sequential()
      Specified by:
      sequential in interface BaseStream<Original,T>
    • parallel Link icon

      public S2 parallel()
      Specified by:
      parallel in interface BaseStream<Original,T>
    • unordered Link icon

      public S2 unordered()
      Specified by:
      unordered in interface BaseStream<Original,T>
    • onClose Link icon

      public S2 onClose(Runnable closeHandler)
      Specified by:
      onClose in interface BaseStream<Original,T>
    • close Link icon

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface BaseStream<Original,T>
    • isPrimaryOwner Link icon

      protected boolean isPrimaryOwner(ConsistentHash ch, Object key)
    • composeWithExceptions Link icon

      Given two SegmentCompletionListener, return a SegmentCompletionListener that executes both in sequence, even if the first throws an exception, and if both throw exceptions, add any exceptions thrown by the second as suppressed exceptions of the first.