Uses of Interface
org.infinispan.LongCacheStream

Packages that use LongCacheStream

Package	Description
org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.
org.infinispan.stream.impl
org.infinispan.stream.impl.local
org.infinispan.util	General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and collections and containers designed to supplement the JDK-provided containers.

Uses of LongCacheStream in org.infinispan

Methods in org.infinispan that return LongCacheStream

Modifier and Type	Method and Description
LongCacheStream	IntCacheStream.asLongStream()
LongCacheStream	LongCacheStream.disableRehashAware() Disables tracking of rehash events that could occur to the underlying cache.
LongCacheStream	LongCacheStream.distinct()
LongCacheStream	LongCacheStream.distributedBatchSize(int batchSize) Controls how many keys are returned from a remote node when using a stream terminal operation with a distributed cache to back this stream.
LongCacheStream	LongCacheStream.filter(LongPredicate predicate)
default LongCacheStream	LongCacheStream.filter(SerializableLongPredicate predicate) Same as filter(LongPredicate) except that the LongPredicate must also implement Serializable.
LongCacheStream	LongCacheStream.filterKeys(Set<?> keys) Filters which entries are returned by only returning ones that map to the given key.
LongCacheStream	LongCacheStream.filterKeySegments(Set<Integer> segments) Filters which entries are returned by what segment they are present in.
LongCacheStream	LongCacheStream.flatMap(LongFunction<? extends LongStream> mapper)
default LongCacheStream	LongCacheStream.flatMap(SerializableLongFunction<? extends LongStream> mapper) Same as flatMap(LongFunction) except that the LongFunction must also implement Serializable.
LongCacheStream	CacheStream.flatMapToLong(Function<? super R,? extends LongStream> mapper)
default LongCacheStream	CacheStream.flatMapToLong(SerializableFunction<? super R,? extends LongStream> mapper) Same as CacheStream.flatMapToLong(Function) except that the Function must also implement Serializable
LongCacheStream	LongCacheStream.limit(long maxSize)
LongCacheStream	LongCacheStream.map(LongUnaryOperator mapper)
default LongCacheStream	LongCacheStream.map(SerializableLongUnaryOperator mapper) Same as map(LongUnaryOperator) except that the LongUnaryOperator must also implement Serializable.
LongCacheStream	DoubleCacheStream.mapToLong(DoubleToLongFunction mapper)
LongCacheStream	IntCacheStream.mapToLong(IntToLongFunction mapper)
default LongCacheStream	DoubleCacheStream.mapToLong(SerializableDoubleToLongFunction mapper) Same as DoubleCacheStream.mapToLong(DoubleToLongFunction) except that the DoubleToLongFunction must also implement Serializable
default LongCacheStream	IntCacheStream.mapToLong(SerializableIntToLongFunction mapper) Same as IntCacheStream.mapToLong(IntToLongFunction) except that the IntToLongFunction must also implement Serializable
default LongCacheStream	CacheStream.mapToLong(SerializableToLongFunction<? super R> mapper) Same as CacheStream.mapToLong(ToLongFunction) except that the ToLongFunction must also implement Serializable
LongCacheStream	CacheStream.mapToLong(ToLongFunction<? super R> mapper)
LongCacheStream	LongCacheStream.onClose(Runnable closeHandler)
LongCacheStream	LongCacheStream.parallel()
LongCacheStream	LongCacheStream.parallelDistribution()
LongCacheStream	LongCacheStream.peek(LongConsumer action)
default LongCacheStream	LongCacheStream.peek(SerializableLongConsumer action) Same as flatMap(LongFunction) except that the LongFunction must also implement Serializable.
LongCacheStream	LongCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) Allows registration of a segment completion listener that is notified when a segment has completed processing.
LongCacheStream	LongCacheStream.sequential()
LongCacheStream	LongCacheStream.sequentialDistribution() This would disable sending requests to all other remote nodes compared to one at a time.
LongCacheStream	LongCacheStream.skip(long n)
LongCacheStream	LongCacheStream.sorted()
LongCacheStream	LongCacheStream.timeout(long timeout, TimeUnit unit) Sets a given time to wait for a remote operation to respond by.
LongCacheStream	LongCacheStream.unordered()

Uses of LongCacheStream in org.infinispan.stream.impl

Classes in org.infinispan.stream.impl that implement LongCacheStream

Modifier and Type	Class and Description
class	DistributedLongCacheStream<Original> Implementation of LongStream that utilizes a lazily evaluated distributed back end execution.
class	IntermediateLongCacheStream An intermediate long cache stream used when an intermediate operation that requires both a remote and local portion

Methods in org.infinispan.stream.impl that return LongCacheStream

Modifier and Type	Method and Description
LongCacheStream	DistributedIntCacheStream.asLongStream()
LongCacheStream	IntermediateIntCacheStream.asLongStream()
LongCacheStream	DistributedLongCacheStream.disableRehashAware()
LongCacheStream	IntermediateLongCacheStream.disableRehashAware()
LongCacheStream	DistributedLongCacheStream.distinct()
LongCacheStream	IntermediateLongCacheStream.distinct()
LongCacheStream	DistributedLongCacheStream.distributedBatchSize(int batchSize)
LongCacheStream	IntermediateLongCacheStream.distributedBatchSize(int batchSize)
LongCacheStream	DistributedLongCacheStream.filter(LongPredicate predicate)
LongCacheStream	IntermediateLongCacheStream.filter(LongPredicate predicate)
LongCacheStream	DistributedLongCacheStream.filter(SerializableLongPredicate predicate)
LongCacheStream	DistributedLongCacheStream.filterKeys(Set<?> keys)
LongCacheStream	IntermediateLongCacheStream.filterKeys(Set<?> keys)
LongCacheStream	DistributedLongCacheStream.filterKeySegments(IntSet segments)
LongCacheStream	IntermediateLongCacheStream.filterKeySegments(IntSet segments)
LongCacheStream	DistributedLongCacheStream.filterKeySegments(Set<Integer> segments)
LongCacheStream	IntermediateLongCacheStream.filterKeySegments(Set<Integer> segments)
LongCacheStream	DistributedLongCacheStream.flatMap(LongFunction<? extends LongStream> mapper)
LongCacheStream	IntermediateLongCacheStream.flatMap(LongFunction<? extends LongStream> mapper)
LongCacheStream	DistributedLongCacheStream.flatMap(SerializableLongFunction<? extends LongStream> mapper)
LongCacheStream	DistributedCacheStream.flatMapToLong(Function<? super R,? extends LongStream> mapper)
LongCacheStream	IntermediateCacheStream.flatMapToLong(Function<? super R,? extends LongStream> mapper)
LongCacheStream	DistributedLongCacheStream.limit(long maxSize)
LongCacheStream	IntermediateLongCacheStream.limit(long maxSize)
LongCacheStream	DistributedLongCacheStream.map(LongUnaryOperator mapper)
LongCacheStream	IntermediateLongCacheStream.map(LongUnaryOperator mapper)
LongCacheStream	DistributedLongCacheStream.map(SerializableLongUnaryOperator mapper)
LongCacheStream	DistributedDoubleCacheStream.mapToLong(DoubleToLongFunction mapper)
LongCacheStream	IntermediateDoubleCacheStream.mapToLong(DoubleToLongFunction mapper)
LongCacheStream	DistributedIntCacheStream.mapToLong(IntToLongFunction mapper)
LongCacheStream	IntermediateIntCacheStream.mapToLong(IntToLongFunction mapper)
LongCacheStream	DistributedDoubleCacheStream.mapToLong(SerializableDoubleToLongFunction mapper)
LongCacheStream	DistributedIntCacheStream.mapToLong(SerializableIntToLongFunction mapper)
LongCacheStream	DistributedCacheStream.mapToLong(ToLongFunction<? super R> mapper)
LongCacheStream	IntermediateCacheStream.mapToLong(ToLongFunction<? super R> mapper)
LongCacheStream	IntermediateLongCacheStream.onClose(Runnable closeHandler)
LongCacheStream	IntermediateLongCacheStream.parallel()
LongCacheStream	DistributedLongCacheStream.parallelDistribution()
LongCacheStream	IntermediateLongCacheStream.parallelDistribution()
LongCacheStream	DistributedLongCacheStream.peek(LongConsumer action)
LongCacheStream	IntermediateLongCacheStream.peek(LongConsumer action)
LongCacheStream	DistributedLongCacheStream.peek(SerializableLongConsumer action)
LongCacheStream	DistributedLongCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
LongCacheStream	IntermediateLongCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
LongCacheStream	IntermediateLongCacheStream.sequential()
LongCacheStream	DistributedLongCacheStream.sequentialDistribution()
LongCacheStream	IntermediateLongCacheStream.sequentialDistribution()
LongCacheStream	DistributedLongCacheStream.skip(long n)
LongCacheStream	IntermediateLongCacheStream.skip(long n)
LongCacheStream	DistributedLongCacheStream.sorted()
LongCacheStream	IntermediateLongCacheStream.sorted()
LongCacheStream	DistributedLongCacheStream.timeout(long timeout, TimeUnit unit)
LongCacheStream	IntermediateLongCacheStream.timeout(long timeout, TimeUnit unit)
LongCacheStream	IntermediateLongCacheStream.unordered()
protected LongCacheStream	DistributedLongCacheStream.unwrap()

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

Classes in org.infinispan.stream.impl.local that implement LongCacheStream

Modifier and Type	Class and Description
class	LocalLongCacheStream LongStream that wraps a given stream to allow for additional functionality such as injection of values into various operations

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

Modifier and Type	Method and Description
LongCacheStream	LocalIntCacheStream.asLongStream()

Uses of LongCacheStream in org.infinispan.util

Methods in org.infinispan.util that return LongCacheStream

Modifier and Type	Method and Description
LongCacheStream	AbstractDelegatingCacheStream.flatMapToLong(Function<? super R,? extends LongStream> mapper)
LongCacheStream	AbstractDelegatingCacheStream.mapToLong(ToLongFunction<? super R> mapper)