Uses of Interface
org.infinispan.BaseCacheStream

Packages that use BaseCacheStream

Package	Description
org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.
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 BaseCacheStream in org.infinispan

Subinterfaces of BaseCacheStream in org.infinispan

Modifier and Type	Interface	Description
interface	CacheStream<R>	A Stream that has additional operations to monitor or control behavior when used from a Cache.
interface	DoubleCacheStream	A DoubleStream that has additional methods to allow for Serializable instances.
interface	IntCacheStream	A IntStream that has additional methods to allow for Serializable instances.
interface	LockedStream<K,V>	Stream that allows for operation upon data solely with side effects by using LockedStream.forEach(BiConsumer) where the BiConsumer is invoked while guaranteeing that the entry being passed is properly locked for the entire duration of the invocation.
interface	LongCacheStream	A LongStream that has additional methods to allow for Serializable instances.

Methods in org.infinispan that return BaseCacheStream

Modifier and Type	Method	Description
BaseCacheStream	BaseCacheStream.disableRehashAware()	Disables tracking of rehash events that could occur to the underlying cache.
BaseCacheStream	BaseCacheStream.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.
BaseCacheStream	BaseCacheStream.filterKeys(Set<?> keys)	Filters which entries are returned by only returning ones that map to the given key.
BaseCacheStream	BaseCacheStream.filterKeySegments(Set<Integer> segments)	Deprecated. since 9.3 This is to be replaced by filterKeySegments(IntSet)
BaseCacheStream	BaseCacheStream.filterKeySegments(IntSet segments)	Filters which entries are returned by what segment they are present in.
BaseCacheStream	BaseCacheStream.parallelDistribution()	This would enable sending requests to all other remote nodes when a terminal operator is performed.
BaseCacheStream	BaseCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)	Allows registration of a segment completion listener that is notified when a segment has completed processing.
BaseCacheStream	BaseCacheStream.sequentialDistribution()	This would disable sending requests to all other remote nodes compared to one at a time.
BaseCacheStream	BaseCacheStream.timeout(long timeout, TimeUnit unit)	Sets a given time to wait for a remote operation to respond by.

Uses of BaseCacheStream in org.infinispan.stream.impl

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

Modifier and Type	Class	Description
class	DistributedCacheStream<Original,R>	Implementation of CacheStream that provides support for lazily distributing stream methods to appropriate nodes
class	DistributedDoubleCacheStream<Original>	Implementation of DoubleStream that utilizes a lazily evaluated distributed back end execution.
class	DistributedIntCacheStream<Original>	Implementation of IntStream that utilizes a lazily evaluated distributed back end execution.
class	DistributedLongCacheStream<Original>	Implementation of LongStream that utilizes a lazily evaluated distributed back end execution.
class	IntermediateCacheStream<Original,R>	An intermediate cache stream used when an intermediate operation that requires both a remote and local portion
class	IntermediateDoubleCacheStream	An intermediate double cache stream used when an intermediate operation that requires both a remote and local portion
class	IntermediateIntCacheStream	An intermediate int cache stream used when an intermediate operation that requires both a remote and local portion
class	IntermediateLongCacheStream	An intermediate long cache stream used when an intermediate operation that requires both a remote and local portion
class	LockedStreamImpl<K,V>	Lock Stream implementation that locks a key using the LockManager before and after executing the various code.
class	TxLockedStreamImpl<K,V>	Locked Stream that is designed for transactions.

Methods in org.infinispan.stream.impl with parameters of type BaseCacheStream

Modifier and Type	Method	Description
abstract <T, S extends BaseStream<T, S>> S	IntermediateType.handleStream(BaseCacheStream streamable)

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

Modifier	Constructor	Description
	IntermediateCacheStream(BaseCacheStream remoteStream, IntermediateType type, org.infinispan.stream.impl.local.LocalCacheStream<R> localStream, org.infinispan.stream.impl.IntermediateCacheStreamSupplier supplier)
	IntermediateDoubleCacheStream(BaseCacheStream remoteStream, IntermediateType type, org.infinispan.stream.impl.local.LocalDoubleCacheStream localDoubleStream, org.infinispan.stream.impl.IntermediateCacheStreamSupplier supplier)
	IntermediateIntCacheStream(BaseCacheStream remoteStream, IntermediateType type, org.infinispan.stream.impl.local.LocalIntCacheStream localIntStream, org.infinispan.stream.impl.IntermediateCacheStreamSupplier supplier)
	IntermediateLongCacheStream(BaseCacheStream remoteStream, IntermediateType type, org.infinispan.stream.impl.local.LocalLongCacheStream localLongStream, org.infinispan.stream.impl.IntermediateCacheStreamSupplier supplier)

Uses of BaseCacheStream in org.infinispan.util

Classes in org.infinispan.util that implement BaseCacheStream

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