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.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)
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.
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.