Uses of Class
org.infinispan.stream.impl.local.LocalLongCacheStream

Packages that use LocalLongCacheStream

Package	Description
org.infinispan.stream.impl
org.infinispan.stream.impl.local

Uses of LocalLongCacheStream in org.infinispan.stream.impl

Constructors in org.infinispan.stream.impl with parameters of type LocalLongCacheStream

Constructor and Description
IntermediateLongCacheStream(BaseCacheStream remoteStream, IntermediateType type, LocalLongCacheStream localLongStream, org.infinispan.stream.impl.IntermediateCacheStreamSupplier supplier)

Uses of LocalLongCacheStream in org.infinispan.stream.impl.local

Methods in org.infinispan.stream.impl.local that return LocalLongCacheStream

Modifier and Type	Method and Description
LocalLongCacheStream	LocalLongCacheStream.disableRehashAware()
LocalLongCacheStream	LocalLongCacheStream.distinct()
LocalLongCacheStream	LocalLongCacheStream.distributedBatchSize(int batchSize)
LocalLongCacheStream	LocalLongCacheStream.filter(LongPredicate predicate)
LocalLongCacheStream	LocalLongCacheStream.filterKeys(Set<?> keys)
LocalLongCacheStream	LocalLongCacheStream.filterKeySegments(IntSet segments)
LocalLongCacheStream	LocalLongCacheStream.filterKeySegments(Set<Integer> segments)
LocalLongCacheStream	LocalLongCacheStream.flatMap(LongFunction<? extends LongStream> mapper)
LocalLongCacheStream	LocalCacheStream.flatMapToLong(Function<? super R,? extends LongStream> mapper)
LocalLongCacheStream	LocalLongCacheStream.limit(long maxSize)
LocalLongCacheStream	LocalLongCacheStream.map(LongUnaryOperator mapper)
LocalLongCacheStream	LocalDoubleCacheStream.mapToLong(DoubleToLongFunction mapper)
LocalLongCacheStream	LocalIntCacheStream.mapToLong(IntToLongFunction mapper)
LocalLongCacheStream	LocalCacheStream.mapToLong(ToLongFunction<? super R> mapper)
LocalLongCacheStream	LocalLongCacheStream.parallelDistribution()
LocalLongCacheStream	LocalLongCacheStream.peek(LongConsumer action)
LocalLongCacheStream	LocalLongCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
LocalLongCacheStream	LocalLongCacheStream.sequentialDistribution()
LocalLongCacheStream	LocalLongCacheStream.skip(long n)
LocalLongCacheStream	LocalLongCacheStream.sorted()
LocalLongCacheStream	LocalLongCacheStream.timeout(long timeout, TimeUnit unit)