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.

Uses of BaseCacheStream in org.infinispan

Subinterfaces of BaseCacheStream in org.infinispan

Modifier and Type	Interface and 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 and 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(IntSet segments) Filters which entries are returned by what segment they are present in.
BaseCacheStream	BaseCacheStream.filterKeySegments(Set<Integer> segments) Deprecated. since 9.3 This is to be replaced by filterKeySegments(IntSet)
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.