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.
org.infinispan.cache.impl
org.infinispan.security.impl
org.infinispan.stream.impl

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 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(SerializablePredicate<? super 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(org.infinispan.commons.util.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.

Uses of LockedStream in org.infinispan.cache.impl

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

Modifier and Type	Method	Description
LockedStream<K,V>	AbstractDelegatingAdvancedCache.lockedStream()
LockedStream<K,V>	CacheImpl.lockedStream()
LockedStream<K,V>	DecoratedCache.lockedStream()
LockedStream<K,V>	SimpleCacheImpl.lockedStream()

Uses of LockedStream in org.infinispan.security.impl

Methods in org.infinispan.security.impl that return LockedStream

Modifier and Type	Method	Description
LockedStream<K,V>	SecureCacheImpl.lockedStream()

Uses of LockedStream in org.infinispan.stream.impl

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

Modifier and Type	Class	Description
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 that return LockedStream

Modifier and Type	Method	Description
LockedStream<K,V>	LockedStreamImpl.disableRehashAware()
LockedStream<K,V>	LockedStreamImpl.distributedBatchSize(int batchSize)
LockedStream<K,V>	LockedStreamImpl.filter(Predicate<? super CacheEntry<K,V>> predicate)
LockedStream<K,V>	LockedStreamImpl.filterKeys(Set<?> keys)
LockedStream<K,V>	LockedStreamImpl.filterKeySegments(Set<Integer> segments)
LockedStream<K,V>	LockedStreamImpl.filterKeySegments(org.infinispan.commons.util.IntSet segments)
LockedStream<K,V>	LockedStreamImpl.onClose(Runnable closeHandler)
LockedStream<K,V>	LockedStreamImpl.parallel()
LockedStream<K,V>	LockedStreamImpl.parallelDistribution()
LockedStream	LockedStreamImpl.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
LockedStream<K,V>	LockedStreamImpl.sequential()
LockedStream<K,V>	LockedStreamImpl.sequentialDistribution()
LockedStream	LockedStreamImpl.timeout(long timeout, TimeUnit unit)
LockedStream<K,V>	LockedStreamImpl.unordered()