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<R>	CacheStream.disableRehashAware() Disables tracking of rehash events that could occur to the underlying cache.
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.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.
CacheStream<R>	CacheStream.parallelDistribution() This would enable sending requests to all other remote nodes when a terminal operator is performed.
CacheStream<E>	CacheCollection.parallelStream()
CacheStream<R>	CacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener) Allows registration of a segment completion listener that is notified when a segment has completed processing.
CacheStream<R>	CacheStream.sequentialDistribution() This would disable sending requests to all other remote nodes compared to one at a time.
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.