Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
Modifier and Type | Method and Description |
---|---|
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> |
AdvancedCache.lockedStream()
Returns a sequential stream using this Cache as the source.
|
LockedStream |
LockedStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
This method is not supported when using a
LockedStream |
LockedStream |
LockedStream.timeout(long time,
TimeUnit unit)
Sets the timeout for the acquisition of the lock for each entry.
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.