Uses of Interface
org.infinispan.IntCacheStream

Packages that use IntCacheStream

Package	Description
org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.

Uses of IntCacheStream in org.infinispan

Methods in org.infinispan that return IntCacheStream

Modifier and Type	Method	Description
IntCacheStream	IntCacheStream.disableRehashAware()	Disables tracking of rehash events that could occur to the underlying cache.
IntCacheStream	IntCacheStream.distinct()
IntCacheStream	IntCacheStream.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.
IntCacheStream	IntCacheStream.filter(IntPredicate predicate)
default IntCacheStream	IntCacheStream.filter(org.infinispan.util.function.SerializableIntPredicate predicate)	Same as filter(IntPredicate) except that the IntPredicate must also implement Serializable
IntCacheStream	IntCacheStream.filterKeys(Set<?> keys)	Filters which entries are returned by only returning ones that map to the given key.
IntCacheStream	IntCacheStream.filterKeySegments(Set<Integer> segments)	Filters which entries are returned by what segment they are present in.
IntCacheStream	IntCacheStream.flatMap(IntFunction<? extends IntStream> mapper)
default IntCacheStream	IntCacheStream.flatMap(org.infinispan.util.function.SerializableIntFunction<? extends IntStream> mapper)	Same as flatMap(IntFunction) except that the IntFunction must also implement Serializable
IntCacheStream	CacheStream.flatMapToInt(Function<? super R,? extends IntStream> mapper)
default IntCacheStream	CacheStream.flatMapToInt(org.infinispan.util.function.SerializableFunction<? super R,? extends IntStream> mapper)	Same as CacheStream.flatMapToInt(Function) except that the Function must also implement Serializable
IntCacheStream	IntCacheStream.limit(long maxSize)
IntCacheStream	IntCacheStream.map(IntUnaryOperator mapper)
default IntCacheStream	IntCacheStream.map(org.infinispan.util.function.SerializableIntUnaryOperator mapper)	Same as map(IntUnaryOperator) except that the IntUnaryOperator must also implement Serializable
IntCacheStream	CacheStream.mapToInt(ToIntFunction<? super R> mapper)
default IntCacheStream	CacheStream.mapToInt(org.infinispan.util.function.SerializableToIntFunction<? super R> mapper)	Same as CacheStream.mapToInt(ToIntFunction) except that the ToIntFunction must also implement Serializable
IntCacheStream	DoubleCacheStream.mapToInt(DoubleToIntFunction mapper)
default IntCacheStream	DoubleCacheStream.mapToInt(org.infinispan.util.function.SerializableDoubleToIntFunction mapper)	Same as DoubleCacheStream.mapToInt(DoubleToIntFunction) except that the DoubleToIntFunction must also implement Serializable
IntCacheStream	LongCacheStream.mapToInt(LongToIntFunction mapper)
default IntCacheStream	LongCacheStream.mapToInt(org.infinispan.util.function.SerializableLongToIntFunction mapper)	Same as LongCacheStream.mapToInt(LongToIntFunction) except that the LongToIntFunction must also implement Serializable.
IntCacheStream	IntCacheStream.onClose(Runnable closeHandler)
IntCacheStream	IntCacheStream.parallel()
IntCacheStream	IntCacheStream.parallelDistribution()
IntCacheStream	IntCacheStream.peek(IntConsumer action)
default IntCacheStream	IntCacheStream.peek(org.infinispan.util.function.SerializableIntConsumer action)	Same as flatMap(IntFunction) except that the IntFunction must also implement Serializable
IntCacheStream	IntCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)	Allows registration of a segment completion listener that is notified when a segment has completed processing.
IntCacheStream	IntCacheStream.sequential()
IntCacheStream	IntCacheStream.sequentialDistribution()	This would disable sending requests to all other remote nodes compared to one at a time.
IntCacheStream	IntCacheStream.skip(long n)
IntCacheStream	IntCacheStream.sorted()
IntCacheStream	IntCacheStream.timeout(long timeout, TimeUnit unit)	Sets a given time to wait for a remote operation to respond by.
IntCacheStream	IntCacheStream.unordered()