Uses of Interface
org.infinispan.IntCacheStream
Packages that use IntCacheStream
Package
Description
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
-
Uses of IntCacheStream in org.infinispan
Methods in org.infinispan that return IntCacheStreamModifier and TypeMethodDescriptionIntCacheStream.disableRehashAware()Disables tracking of rehash events that could occur to the underlying cache.IntCacheStream.distinct()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.filter(IntPredicate predicate) default IntCacheStreamIntCacheStream.filter(org.infinispan.util.function.SerializableIntPredicate predicate) Same asfilter(IntPredicate)except that the IntPredicate must also implementSerializableIntCacheStream.filterKeys(Set<?> keys) Filters which entries are returned by only returning ones that map to the given key.IntCacheStream.filterKeySegments(Set<Integer> segments) Filters which entries are returned by what segment they are present in.IntCacheStream.flatMap(IntFunction<? extends IntStream> mapper) default IntCacheStreamIntCacheStream.flatMap(org.infinispan.util.function.SerializableIntFunction<? extends IntStream> mapper) Same asflatMap(IntFunction)except that the IntFunction must also implementSerializableCacheStream.flatMapToInt(Function<? super R, ? extends IntStream> mapper) default IntCacheStreamCacheStream.flatMapToInt(org.infinispan.util.function.SerializableFunction<? super R, ? extends IntStream> mapper) Same asCacheStream.flatMapToInt(Function)except that the Function must also implementSerializableIntCacheStream.limit(long maxSize) IntCacheStream.map(IntUnaryOperator mapper) default IntCacheStreamIntCacheStream.map(org.infinispan.util.function.SerializableIntUnaryOperator mapper) Same asmap(IntUnaryOperator)except that the IntUnaryOperator must also implementSerializableCacheStream.mapToInt(ToIntFunction<? super R> mapper) default IntCacheStreamSame asCacheStream.mapToInt(ToIntFunction)except that the ToIntFunction must also implementSerializableDoubleCacheStream.mapToInt(DoubleToIntFunction mapper) default IntCacheStreamDoubleCacheStream.mapToInt(org.infinispan.util.function.SerializableDoubleToIntFunction mapper) Same asDoubleCacheStream.mapToInt(DoubleToIntFunction)except that the DoubleToIntFunction must also implementSerializableLongCacheStream.mapToInt(LongToIntFunction mapper) default IntCacheStreamLongCacheStream.mapToInt(org.infinispan.util.function.SerializableLongToIntFunction mapper) Same asLongCacheStream.mapToInt(LongToIntFunction)except that the LongToIntFunction must also implement Serializable.IntCacheStream.parallel()IntCacheStream.parallelDistribution()IntCacheStream.peek(IntConsumer action) default IntCacheStreamIntCacheStream.peek(org.infinispan.util.function.SerializableIntConsumer action) Same asflatMap(IntFunction)except that the IntFunction must also implementSerializableIntCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) Allows registration of a segment completion listener that is notified when a segment has completed processing.IntCacheStream.sequential()IntCacheStream.sequentialDistribution()This would disable sending requests to all other remote nodes compared to one at a time.IntCacheStream.skip(long n) IntCacheStream.sorted()Sets a given time to wait for a remote operation to respond by.IntCacheStream.unordered()