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.

Uses of LongCacheStream in org.infinispan

Methods in org.infinispan that return LongCacheStream

Modifier and Type	Method	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(org.infinispan.util.function.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(org.infinispan.util.function.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(org.infinispan.util.function.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(org.infinispan.util.function.SerializableLongUnaryOperator mapper)	Same as map(LongUnaryOperator) except that the LongUnaryOperator must also implement Serializable.
LongCacheStream	CacheStream.mapToLong(ToLongFunction<? super R> mapper)
default LongCacheStream	CacheStream.mapToLong(org.infinispan.util.function.SerializableToLongFunction<? super R> mapper)	Same as CacheStream.mapToLong(ToLongFunction) except that the ToLongFunction must also implement Serializable
LongCacheStream	DoubleCacheStream.mapToLong(DoubleToLongFunction mapper)
default LongCacheStream	DoubleCacheStream.mapToLong(org.infinispan.util.function.SerializableDoubleToLongFunction mapper)	Same as DoubleCacheStream.mapToLong(DoubleToLongFunction) except that the DoubleToLongFunction must also implement Serializable
LongCacheStream	IntCacheStream.mapToLong(IntToLongFunction mapper)
default LongCacheStream	IntCacheStream.mapToLong(org.infinispan.util.function.SerializableIntToLongFunction mapper)	Same as IntCacheStream.mapToLong(IntToLongFunction) except that the IntToLongFunction must also implement Serializable
LongCacheStream	LongCacheStream.onClose(Runnable closeHandler)
LongCacheStream	LongCacheStream.parallel()
LongCacheStream	LongCacheStream.parallelDistribution()
LongCacheStream	LongCacheStream.peek(LongConsumer action)
default LongCacheStream	LongCacheStream.peek(org.infinispan.util.function.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()