Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
Modifier and Type | Method and Description |
---|---|
IntCacheStream |
IntCacheStream.disableRehashAware()
Disables tracking of rehash events that could occur to the underlying cache.
|
IntCacheStream |
IntCacheStream.distinct() |
IntCacheStream |
IntCacheStream.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.
|
IntCacheStream |
IntCacheStream.filter(IntPredicate predicate) |
default IntCacheStream |
IntCacheStream.filter(SerializableIntPredicate predicate)
Same as
filter(IntPredicate) except that the IntPredicate must also
implement Serializable |
IntCacheStream |
IntCacheStream.filterKeys(Set<?> keys)
Filters which entries are returned by only returning ones that map to the given key.
|
IntCacheStream |
IntCacheStream.filterKeySegments(Set<Integer> segments)
Filters which entries are returned by what segment they are present in.
|
IntCacheStream |
IntCacheStream.flatMap(IntFunction<? extends IntStream> mapper) |
default IntCacheStream |
IntCacheStream.flatMap(SerializableIntFunction<? extends IntStream> mapper)
Same as
flatMap(IntFunction) except that the IntFunction must also
implement Serializable |
IntCacheStream |
CacheStream.flatMapToInt(Function<? super R,? extends IntStream> mapper) |
default IntCacheStream |
CacheStream.flatMapToInt(SerializableFunction<? super R,? extends IntStream> mapper)
Same as
CacheStream.flatMapToInt(Function) except that the Function must also
implement Serializable |
IntCacheStream |
IntCacheStream.limit(long maxSize) |
IntCacheStream |
IntCacheStream.map(IntUnaryOperator mapper) |
default IntCacheStream |
IntCacheStream.map(SerializableIntUnaryOperator mapper)
Same as
map(IntUnaryOperator) except that the IntUnaryOperator must also
implement Serializable |
IntCacheStream |
DoubleCacheStream.mapToInt(DoubleToIntFunction mapper) |
IntCacheStream |
LongCacheStream.mapToInt(LongToIntFunction mapper) |
default IntCacheStream |
DoubleCacheStream.mapToInt(SerializableDoubleToIntFunction mapper)
Same as
DoubleCacheStream.mapToInt(DoubleToIntFunction) except that the DoubleToIntFunction must also
implement Serializable |
default IntCacheStream |
LongCacheStream.mapToInt(SerializableLongToIntFunction mapper)
Same as
LongCacheStream.mapToInt(LongToIntFunction) except that the LongToIntFunction must also
implement Serializable. |
default IntCacheStream |
CacheStream.mapToInt(SerializableToIntFunction<? super R> mapper)
Same as
CacheStream.mapToInt(ToIntFunction) except that the ToIntFunction must also
implement Serializable |
IntCacheStream |
CacheStream.mapToInt(ToIntFunction<? super R> mapper) |
IntCacheStream |
IntCacheStream.onClose(Runnable closeHandler) |
IntCacheStream |
IntCacheStream.parallel() |
IntCacheStream |
IntCacheStream.parallelDistribution() |
IntCacheStream |
IntCacheStream.peek(IntConsumer action) |
default IntCacheStream |
IntCacheStream.peek(SerializableIntConsumer action)
Same as
flatMap(IntFunction) except that the IntFunction must also
implement Serializable |
IntCacheStream |
IntCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
Allows registration of a segment completion listener that is notified when a segment has completed
processing.
|
IntCacheStream |
IntCacheStream.sequential() |
IntCacheStream |
IntCacheStream.sequentialDistribution()
This would disable sending requests to all other remote nodes compared to one at a time.
|
IntCacheStream |
IntCacheStream.skip(long n) |
IntCacheStream |
IntCacheStream.sorted() |
IntCacheStream |
IntCacheStream.timeout(long timeout,
TimeUnit unit)
Sets a given time to wait for a remote operation to respond by.
|
IntCacheStream |
IntCacheStream.unordered() |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.