Uses of Interface
org.infinispan.DoubleCacheStream
Packages that use DoubleCacheStream
Package
Description
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
-
Uses of DoubleCacheStream in org.infinispan
Methods in org.infinispan that return DoubleCacheStreamModifier and TypeMethodDescriptionIntCacheStream.asDoubleStream()LongCacheStream.asDoubleStream()DoubleCacheStream.disableRehashAware()Disables tracking of rehash events that could occur to the underlying cache.DoubleCacheStream.distinct()DoubleCacheStream.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.DoubleCacheStream.filter(DoublePredicate predicate) default DoubleCacheStreamDoubleCacheStream.filter(org.infinispan.util.function.SerializableDoublePredicate predicate) Same asfilter(DoublePredicate)except that the DoublePredicate must also implementSerializableDoubleCacheStream.filterKeys(Set<?> keys) Filters which entries are returned by only returning ones that map to the given key.DoubleCacheStream.filterKeySegments(Set<Integer> segments) Filters which entries are returned by what segment they are present in.DoubleCacheStream.flatMap(DoubleFunction<? extends DoubleStream> mapper) default DoubleCacheStreamDoubleCacheStream.flatMap(org.infinispan.util.function.SerializableDoubleFunction<? extends DoubleStream> mapper) Same asflatMap(DoubleFunction)except that the DoubleFunction must also implementSerializableCacheStream.flatMapToDouble(Function<? super R, ? extends DoubleStream> mapper) default DoubleCacheStreamCacheStream.flatMapToDouble(org.infinispan.util.function.SerializableFunction<? super R, ? extends DoubleStream> mapper) Same asCacheStream.flatMapToDouble(Function)except that the Function must also implementSerializableDoubleCacheStream.limit(long maxSize) DoubleCacheStream.map(DoubleUnaryOperator mapper) default DoubleCacheStreamDoubleCacheStream.map(org.infinispan.util.function.SerializableDoubleUnaryOperator mapper) Same asmap(DoubleUnaryOperator)except that the DoubleUnaryOperator must also implementSerializableCacheStream.mapToDouble(ToDoubleFunction<? super R> mapper) default DoubleCacheStreamCacheStream.mapToDouble(org.infinispan.util.function.SerializableToDoubleFunction<? super R> mapper) Same asCacheStream.mapToDouble(ToDoubleFunction)except that the ToDoubleFunction must also implementSerializableIntCacheStream.mapToDouble(IntToDoubleFunction mapper) default DoubleCacheStreamIntCacheStream.mapToDouble(org.infinispan.util.function.SerializableIntToDoubleFunction mapper) Same asIntCacheStream.mapToDouble(IntToDoubleFunction)except that the IntToIntFunction must also implementSerializableLongCacheStream.mapToDouble(LongToDoubleFunction mapper) default DoubleCacheStreamLongCacheStream.mapToDouble(org.infinispan.util.function.SerializableLongToDoubleFunction mapper) Same asLongCacheStream.mapToDouble(LongToDoubleFunction)except that the LongToLongFunction must also implement Serializable.DoubleCacheStream.parallel()DoubleCacheStream.parallelDistribution()DoubleCacheStream.peek(DoubleConsumer action) default DoubleCacheStreamDoubleCacheStream.peek(org.infinispan.util.function.SerializableDoubleConsumer action) Same asflatMap(DoubleFunction)except that the DoubleFunction must also implementSerializableDoubleCacheStream.segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) Allows registration of a segment completion listener that is notified when a segment has completed processing.DoubleCacheStream.sequential()DoubleCacheStream.sequentialDistribution()This would disable sending requests to all other remote nodes compared to one at a time.DoubleCacheStream.skip(long n) DoubleCacheStream.sorted()Sets a given time to wait for a remote operation to respond by.DoubleCacheStream.unordered()