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 |
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(IntSet segments)
Filters which entries are returned by what segment they are present in.
|
LockedStream<K,V> |
LockedStream.filterKeySegments(Set<Integer> segments)
Deprecated.
This is to be replaced by
filterKeySegments(IntSet) |
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.
|
Modifier and Type | Method and Description |
---|---|
LockedStream<K,V> |
AbstractDelegatingAdvancedCache.lockedStream() |
LockedStream<K,V> |
CacheImpl.lockedStream() |
LockedStream<K,V> |
DecoratedCache.lockedStream() |
LockedStream<K,V> |
SimpleCacheImpl.lockedStream() |
Modifier and Type | Method and Description |
---|---|
LockedStream<K,V> |
SecureCacheImpl.lockedStream() |
Modifier and Type | Class and 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.
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.