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 asfilter(Predicate)
except that the Predicate must also implementSerializable
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 byfilterKeySegments(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 aLockedStream
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 theLockManager
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()
-