Uses of Interface
org.infinispan.LockedStream

Packages that use LockedStream

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

Uses of LockedStream in org.infinispan

Methods in org.infinispan that return LockedStream

Modifier and Type	Method	Description
LockedStream<K,V>	LockedStream.disableRehashAware()	Disables tracking of rehash events that could occur to the underlying cache.
LockedStream<K,V>	LockedStream.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.
LockedStream<K,V>	LockedStream.filter(Predicate<? super org.infinispan.container.entries.CacheEntry<K,V>> predicate)	Returns a locked stream consisting of the elements of this stream that match the given predicate.
default LockedStream<K,V>	LockedStream.filter(org.infinispan.util.function.SerializablePredicate<? super org.infinispan.container.entries.CacheEntry<K,V>> predicate)	Same as filter(Predicate) except that the Predicate must also implement Serializable
LockedStream<K,V>	LockedStream.filterKeys(Set<?> keys)	Filters which entries are returned by only returning ones that map to the given key.
LockedStream<K,V>	LockedStream.filterKeySegments(Set<Integer> segments)	Deprecated. This is to be replaced by filterKeySegments(IntSet)
LockedStream<K,V>	LockedStream.filterKeySegments(IntSet segments)	Filters which entries are returned by what segment they are present in.
LockedStream<K,V>	AdvancedCache.lockedStream()	Returns a sequential stream using this Cache as the source.
LockedStream<K,V>	LockedStream.parallelDistribution()	This would enable sending requests to all other remote nodes when a terminal operator is performed.
LockedStream<K,V>	LockedStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)	This method is not supported when using a LockedStream
LockedStream<K,V>	LockedStream.sequentialDistribution()	This would disable sending requests to all other remote nodes compared to one at a time.
LockedStream<K,V>	LockedStream.timeout(long time, TimeUnit unit)	Sets the timeout for the acquisition of the lock for each entry.