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.
org.infinispan.cache.impl
org.infinispan.distribution.group.impl
org.infinispan.filter	Provides capabilities around filtering and converting entries that are found in the cache or cache store/loader.
org.infinispan.stream.impl
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 CacheStream in org.infinispan

Methods in org.infinispan that return CacheStream

Modifier and Type	Method	Description
CacheStream<Double>	DoubleCacheStream.boxed()
CacheStream<Integer>	IntCacheStream.boxed()
CacheStream<Long>	LongCacheStream.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)
default 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)	Deprecated. This is to be replaced by filterKeySegments(IntSet)
CacheStream<R>	CacheStream.filterKeySegments(IntSet 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)
default <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)
default <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)
default <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(IntFunction<? extends U> mapper)
default <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(LongFunction<? extends U> mapper)
default <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()
final CacheStream<E>	InternalCacheSet.parallelStream()
CacheStream<R>	CacheStream.peek(Consumer<? super R> action)
default 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)
default CacheStream<R>	CacheStream.sorted(SerializableComparator<? super R> comparator)	Same as sorted(Comparator) except that the Comparator must also implement Serializable
CacheStream<E>	CacheCollection.stream()
final CacheStream<E>	InternalCacheSet.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()

Uses of CacheStream in org.infinispan.cache.impl

Methods in org.infinispan.cache.impl that return CacheStream

Modifier and Type	Method	Description
CacheStream<E>	AbstractCacheBackedSet.parallelStream()
CacheStream<CacheEntry<K,V>>	SimpleCacheImpl.CacheEntrySet.parallelStream()
CacheStream<Map.Entry<K,V>>	SimpleCacheImpl.EntrySet.parallelStream()
CacheStream<K>	SimpleCacheImpl.KeySet.parallelStream()
CacheStream<V>	SimpleCacheImpl.Values.parallelStream()
CacheStream<E>	AbstractCacheBackedSet.stream()
CacheStream<CacheEntry<K,V>>	SimpleCacheImpl.CacheEntrySet.stream()
CacheStream<Map.Entry<K,V>>	SimpleCacheImpl.EntrySet.stream()
CacheStream<K>	SimpleCacheImpl.KeySet.stream()
CacheStream<V>	SimpleCacheImpl.Values.stream()

Uses of CacheStream in org.infinispan.distribution.group.impl

Methods in org.infinispan.distribution.group.impl with parameters of type CacheStream

Modifier and Type	Method	Description
<K, V> Map<K,V>	GroupManager.collect(CacheStream<? extends CacheEntry<K,V>> stream, InvocationContext ctx, String groupName)	Collects all entries belonging to a single group.
<K, V> Map<K,V>	GroupManagerImpl.collect(CacheStream<? extends CacheEntry<K,V>> stream, InvocationContext ctx, String groupName)

Uses of CacheStream in org.infinispan.filter

Methods in org.infinispan.filter that return CacheStream

Modifier and Type	Method	Description
static <K, V, C> CacheStream<CacheEntry<K,C>>	CacheFilters.filterAndConvert(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)
static <K, V, C> CacheStream<K>	CacheFilters.filterAndConvertToKey(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)
static <K, V, C> CacheStream<C>	CacheFilters.filterAndConvertToValue(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)

Methods in org.infinispan.filter with parameters of type CacheStream

Modifier and Type	Method	Description
static <K, V, C> CacheStream<CacheEntry<K,C>>	CacheFilters.filterAndConvert(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)
static <K, V, C> CacheStream<K>	CacheFilters.filterAndConvertToKey(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)
static <K, V, C> CacheStream<C>	CacheFilters.filterAndConvertToValue(CacheStream<CacheEntry<K,V>> stream, KeyValueFilterConverter<? super K,? super V,C> filterConverter)

Uses of CacheStream in org.infinispan.stream.impl

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

Modifier and Type	Class	Description
class	DistributedCacheStream<Original,R>	Implementation of CacheStream that provides support for lazily distributing stream methods to appropriate nodes
class	IntermediateCacheStream<Original,R>	An intermediate cache stream used when an intermediate operation that requires both a remote and local portion

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

Modifier and Type	Method	Description
CacheStream<Double>	DistributedDoubleCacheStream.boxed()
CacheStream<Integer>	DistributedIntCacheStream.boxed()
CacheStream<Long>	DistributedLongCacheStream.boxed()
CacheStream<Double>	IntermediateDoubleCacheStream.boxed()
CacheStream<Integer>	IntermediateIntCacheStream.boxed()
CacheStream<Long>	IntermediateLongCacheStream.boxed()
CacheStream<R>	DistributedCacheStream.disableRehashAware()
CacheStream<R>	IntermediateCacheStream.disableRehashAware()
CacheStream<R>	DistributedCacheStream.distinct()
CacheStream<R>	IntermediateCacheStream.distinct()
CacheStream<R>	DistributedCacheStream.distributedBatchSize(int batchSize)
CacheStream<R>	IntermediateCacheStream.distributedBatchSize(int batchSize)
CacheStream<R>	DistributedCacheStream.filter(Predicate<? super R> predicate)
CacheStream<R>	IntermediateCacheStream.filter(Predicate<? super R> predicate)
CacheStream<R>	DistributedCacheStream.filterKeys(Set<?> keys)
CacheStream<R>	IntermediateCacheStream.filterKeys(Set<?> keys)
CacheStream<R>	DistributedCacheStream.filterKeySegments(Set<Integer> segments)
CacheStream<R>	DistributedCacheStream.filterKeySegments(IntSet segments)
CacheStream<R>	IntermediateCacheStream.filterKeySegments(Set<Integer> segments)
CacheStream<R>	IntermediateCacheStream.filterKeySegments(IntSet segments)
<R1> CacheStream<R1>	DistributedCacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper)
<R1> CacheStream<R1>	IntermediateCacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper)
CacheStream<R>	DistributedCacheStream.limit(long maxSize)
CacheStream<R>	IntermediateCacheStream.limit(long maxSize)
<R1> CacheStream<R1>	DistributedCacheStream.map(Function<? super R,? extends R1> mapper)
<R1> CacheStream<R1>	IntermediateCacheStream.map(Function<? super R,? extends R1> mapper)
<U> CacheStream<U>	DistributedDoubleCacheStream.mapToObj(DoubleFunction<? extends U> mapper)
<U> CacheStream<U>	DistributedDoubleCacheStream.mapToObj(SerializableDoubleFunction<? extends U> mapper)
<U> CacheStream<U>	DistributedIntCacheStream.mapToObj(IntFunction<? extends U> mapper)
<U> CacheStream<U>	DistributedIntCacheStream.mapToObj(SerializableIntFunction<? extends U> mapper)
<U> CacheStream<U>	DistributedLongCacheStream.mapToObj(LongFunction<? extends U> mapper)
<U> CacheStream<U>	DistributedLongCacheStream.mapToObj(SerializableLongFunction<? extends U> mapper)
<U> CacheStream<U>	IntermediateDoubleCacheStream.mapToObj(DoubleFunction<? extends U> mapper)
<U> CacheStream<U>	IntermediateIntCacheStream.mapToObj(IntFunction<? extends U> mapper)
<U> CacheStream<U>	IntermediateLongCacheStream.mapToObj(LongFunction<? extends U> mapper)
CacheStream<R>	IntermediateCacheStream.onClose(Runnable closeHandler)
CacheStream<R>	IntermediateCacheStream.parallel()
CacheStream<R>	DistributedCacheStream.parallelDistribution()
CacheStream<R>	IntermediateCacheStream.parallelDistribution()
CacheStream<R>	DistributedCacheStream.peek(Consumer<? super R> action)
CacheStream<R>	IntermediateCacheStream.peek(Consumer<? super R> action)
CacheStream<R>	DistributedCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
CacheStream<R>	IntermediateCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
CacheStream<R>	IntermediateCacheStream.sequential()
CacheStream<R>	DistributedCacheStream.sequentialDistribution()
CacheStream<R>	IntermediateCacheStream.sequentialDistribution()
CacheStream<R>	DistributedCacheStream.skip(long n)
CacheStream<R>	IntermediateCacheStream.skip(long n)
CacheStream<R>	DistributedCacheStream.sorted()
CacheStream<R>	DistributedCacheStream.sorted(Comparator<? super R> comparator)
CacheStream<R>	IntermediateCacheStream.sorted()
CacheStream<R>	IntermediateCacheStream.sorted(Comparator<? super R> comparator)
CacheStream<R>	DistributedCacheStream.timeout(long timeout, TimeUnit unit)
CacheStream<R>	IntermediateCacheStream.timeout(long timeout, TimeUnit unit)
CacheStream<R>	IntermediateCacheStream.unordered()
protected CacheStream<R>	DistributedCacheStream.unwrap()

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

Modifier	Constructor	Description
	LockedStreamImpl(CacheStream<CacheEntry<K,V>> realStream, long time, TimeUnit unit)
	TxLockedStreamImpl(javax.transaction.TransactionManager tm, CacheStream<CacheEntry<K,V>> realStream, long time, TimeUnit unit)

Uses of CacheStream in org.infinispan.util

Classes in org.infinispan.util that implement CacheStream

Modifier and Type	Class	Description
class	AbstractDelegatingCacheStream<R>	Delegate that forwards all the of the method calls to the underlying cache stream.

Fields in org.infinispan.util declared as CacheStream

Modifier and Type	Field	Description
protected CacheStream<?>	AbstractDelegatingCacheStream.underlyingStream

Methods in org.infinispan.util that return CacheStream

Modifier and Type	Method	Description
CacheStream<R>	AbstractDelegatingCacheStream.distinct()
CacheStream<R>	AbstractDelegatingCacheStream.filter(Predicate<? super R> predicate)
<R1> CacheStream<R1>	AbstractDelegatingCacheStream.flatMap(Function<? super R,? extends Stream<? extends R1>> mapper)
CacheStream<R>	AbstractDelegatingCacheStream.limit(long maxSize)
<R1> CacheStream<R1>	AbstractDelegatingCacheStream.map(Function<? super R,? extends R1> mapper)
CacheStream<R>	AbstractDelegatingCacheStream.onClose(Runnable closeHandler)
CacheStream<R>	AbstractDelegatingCacheStream.parallel()
CacheStream<R>	CacheSetMapper.parallelStream()
CacheStream<R>	WriteableCacheCollectionMapper.parallelStream()
CacheStream<R>	AbstractDelegatingCacheStream.peek(Consumer<? super R> action)
CacheStream<R>	AbstractDelegatingCacheStream.sequential()
CacheStream<R>	AbstractDelegatingCacheStream.skip(long n)
CacheStream<R>	AbstractDelegatingCacheStream.sorted()
CacheStream<R>	AbstractDelegatingCacheStream.sorted(Comparator<? super R> comparator)
CacheStream<R>	CacheSetMapper.stream()
CacheStream<R>	WriteableCacheCollectionMapper.stream()
CacheStream<R>	AbstractDelegatingCacheStream.unordered()

Constructors in org.infinispan.util with parameters of type CacheStream

Modifier	Constructor	Description
	AbstractDelegatingCacheStream(CacheStream<R> stream)