Uses of Interface
org.infinispan.CacheStream

Packages that use CacheStream

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

Uses of CacheStream in org.infinispan

Methods in org.infinispan that return CacheStream

Modifier and Type	Method and Description
CacheStream<Long>	LongCacheStream.boxed()
CacheStream<Integer>	IntCacheStream.boxed()
CacheStream<Double>	DoubleCacheStream.boxed()
CacheStream<R>	CacheStream.disableRehashAware() Disables tracking of rehash events that could occur to the underlying cache.
CacheStream<R>	CacheStream.distinct()
CacheStream<R>	CacheStream.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.
CacheStream<R>	CacheStream.filter(Predicate<? super R> predicate)
CacheStream<R>	CacheStream.filter(SerializablePredicate<? super R> predicate) Same as filter(Predicate) except that the Predicate must also implement Serializable
CacheStream<R>	CacheStream.filterKeys(Set<?> keys) Filters which entries are returned by only returning ones that map to the given key.
CacheStream<R>	CacheStream.filterKeySegments(Set<Integer> segments) Filters which entries are returned by what segment they are present in.
<R1> CacheStream<R1>	CacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper)
<R1> CacheStream<R1>	CacheStream.flatMap(SerializableFunction<? super R,? extends Stream<? extends R1>> mapper) Same as flatMap(Function) except that the Function must also implement Serializable
CacheStream<R>	CacheStream.limit(long maxSize)
<R1> CacheStream<R1>	CacheStream.map(Function<? super R,? extends R1> mapper)
<R1> CacheStream<R1>	CacheStream.map(SerializableFunction<? super R,? extends R1> mapper) Same as map(Function) except that the Function must also implement Serializable
<U> CacheStream<U>	DoubleCacheStream.mapToObj(DoubleFunction<? extends U> mapper)
<U> CacheStream<U>	IntCacheStream.mapToObj(IntFunction<? extends U> mapper)
<U> CacheStream<U>	LongCacheStream.mapToObj(LongFunction<? extends U> mapper)
<U> CacheStream<U>	DoubleCacheStream.mapToObj(SerializableDoubleFunction<? extends U> mapper) Same as DoubleCacheStream.mapToObj(DoubleFunction) except that the DoubleFunction must also implement Serializable
<U> CacheStream<U>	IntCacheStream.mapToObj(SerializableIntFunction<? extends U> mapper) Same as IntCacheStream.mapToObj(IntFunction) except that the IntFunction must also implement Serializable
<U> CacheStream<U>	LongCacheStream.mapToObj(SerializableLongFunction<? extends U> mapper) Same as LongCacheStream.mapToObj(LongFunction) except that the LongFunction must also implement Serializable.
CacheStream<R>	CacheStream.onClose(Runnable closeHandler)
CacheStream<R>	CacheStream.parallel()
CacheStream<R>	CacheStream.parallelDistribution()
CacheStream<E>	CacheCollection.parallelStream()
CacheStream<R>	CacheStream.peek(Consumer<? super R> action)
CacheStream<R>	CacheStream.peek(SerializableConsumer<? super R> action) Same as peek(Consumer) except that the Consumer must also implement Serializable
CacheStream<R>	CacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) Allows registration of a segment completion listener that is notified when a segment has completed processing.
CacheStream<R>	CacheStream.sequential()
CacheStream<R>	CacheStream.sequentialDistribution() This would disable sending requests to all other remote nodes compared to one at a time.
CacheStream<R>	CacheStream.skip(long n)
CacheStream<R>	CacheStream.sorted()
CacheStream<R>	CacheStream.sorted(Comparator<? super R> comparator)
CacheStream<R>	CacheStream.sorted(SerializableComparator<? super R> comparator) Same as sorted(Comparator) except that the Comparator must also implement Serializable
CacheStream<E>	CacheCollection.stream()
CacheStream<R>	CacheStream.timeout(long timeout, TimeUnit unit) Sets a given time to wait for a remote operation to respond by.
CacheStream<R>	CacheStream.unordered()