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

Subinterfaces with type arguments of type LockedStream in org.infinispan

Modifier and Type	Interface	Description
interface	LockedStream<K,V>	Stream that allows for operation upon data solely with side effects by using forEach(BiConsumer) where the BiConsumer is invoked while guaranteeing that the entry being passed is properly locked for the entire duration of the invocation.

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(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(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()