Uses of Interface
org.infinispan.DoubleCacheStream
Package
Description
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and
collections and containers designed to supplement the JDK-provided containers.
-
Uses of DoubleCacheStream in org.infinispan
Modifier 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 DoubleCacheStream
DoubleCacheStream.filter
(SerializableDoublePredicate predicate) Same asfilter(DoublePredicate)
except that the DoublePredicate must also implementSerializable
DoubleCacheStream.filterKeys
(Set<?> keys) Filters which entries are returned by only returning ones that map to the given key.DoubleCacheStream.flatMap
(DoubleFunction<? extends DoubleStream> mapper) default DoubleCacheStream
DoubleCacheStream.flatMap
(SerializableDoubleFunction<? extends DoubleStream> mapper) Same asflatMap(DoubleFunction)
except that the DoubleFunction must also implementSerializable
CacheStream.flatMapToDouble
(Function<? super R, ? extends DoubleStream> mapper) default DoubleCacheStream
CacheStream.flatMapToDouble
(SerializableFunction<? super R, ? extends DoubleStream> mapper) Same asCacheStream.flatMapToDouble(Function)
except that the Function must also implementSerializable
DoubleCacheStream.limit
(long maxSize) DoubleCacheStream.map
(DoubleUnaryOperator mapper) default DoubleCacheStream
DoubleCacheStream.map
(SerializableDoubleUnaryOperator mapper) Same asmap(DoubleUnaryOperator)
except that the DoubleUnaryOperator must also implementSerializable
CacheStream.mapToDouble
(ToDoubleFunction<? super R> mapper) default DoubleCacheStream
CacheStream.mapToDouble
(SerializableToDoubleFunction<? super R> mapper) Same asCacheStream.mapToDouble(ToDoubleFunction)
except that the ToDoubleFunction must also implementSerializable
IntCacheStream.mapToDouble
(IntToDoubleFunction mapper) default DoubleCacheStream
IntCacheStream.mapToDouble
(SerializableIntToDoubleFunction mapper) Same asIntCacheStream.mapToDouble(IntToDoubleFunction)
except that the IntToIntFunction must also implementSerializable
LongCacheStream.mapToDouble
(LongToDoubleFunction mapper) default DoubleCacheStream
LongCacheStream.mapToDouble
(SerializableLongToDoubleFunction mapper) Same asLongCacheStream.mapToDouble(LongToDoubleFunction)
except that the LongToLongFunction must also implement Serializable.DoubleCacheStream.parallel()
DoubleCacheStream.parallelDistribution()
DoubleCacheStream.peek
(DoubleConsumer action) default DoubleCacheStream
DoubleCacheStream.peek
(SerializableDoubleConsumer action) Same asflatMap(DoubleFunction)
except that the DoubleFunction must also implementSerializable
DoubleCacheStream.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()
-
Uses of DoubleCacheStream in org.infinispan.stream.impl
Modifier and TypeClassDescriptionclass
DistributedDoubleCacheStream<Original>
Implementation ofDoubleStream
that utilizes a lazily evaluated distributed back end execution.class
An intermediate double cache stream used when an intermediate operation that requires both a remote and local portionModifier and TypeMethodDescriptionDistributedIntCacheStream.asDoubleStream()
DistributedLongCacheStream.asDoubleStream()
IntermediateIntCacheStream.asDoubleStream()
IntermediateLongCacheStream.asDoubleStream()
DistributedDoubleCacheStream.disableRehashAware()
IntermediateDoubleCacheStream.disableRehashAware()
DistributedDoubleCacheStream.distinct()
IntermediateDoubleCacheStream.distinct()
DistributedDoubleCacheStream.distributedBatchSize
(int batchSize) IntermediateDoubleCacheStream.distributedBatchSize
(int batchSize) DistributedDoubleCacheStream.filter
(DoublePredicate predicate) DistributedDoubleCacheStream.filter
(SerializableDoublePredicate predicate) IntermediateDoubleCacheStream.filter
(DoublePredicate predicate) DistributedDoubleCacheStream.filterKeys
(Set<?> keys) IntermediateDoubleCacheStream.filterKeys
(Set<?> keys) DistributedDoubleCacheStream.filterKeySegments
(IntSet segments) IntermediateDoubleCacheStream.filterKeySegments
(IntSet segments) DistributedDoubleCacheStream.flatMap
(DoubleFunction<? extends DoubleStream> mapper) DistributedDoubleCacheStream.flatMap
(SerializableDoubleFunction<? extends DoubleStream> mapper) IntermediateDoubleCacheStream.flatMap
(DoubleFunction<? extends DoubleStream> mapper) DistributedCacheStream.flatMapToDouble
(Function<? super R, ? extends DoubleStream> mapper) IntermediateCacheStream.flatMapToDouble
(Function<? super R, ? extends DoubleStream> mapper) DistributedDoubleCacheStream.limit
(long maxSize) IntermediateDoubleCacheStream.limit
(long maxSize) DistributedDoubleCacheStream.map
(DoubleUnaryOperator mapper) DistributedDoubleCacheStream.map
(SerializableDoubleUnaryOperator mapper) IntermediateDoubleCacheStream.map
(DoubleUnaryOperator mapper) DistributedCacheStream.mapToDouble
(ToDoubleFunction<? super R> mapper) DistributedIntCacheStream.mapToDouble
(IntToDoubleFunction mapper) DistributedIntCacheStream.mapToDouble
(SerializableIntToDoubleFunction mapper) DistributedLongCacheStream.mapToDouble
(LongToDoubleFunction mapper) DistributedLongCacheStream.mapToDouble
(SerializableLongToDoubleFunction mapper) IntermediateCacheStream.mapToDouble
(ToDoubleFunction<? super R> mapper) IntermediateIntCacheStream.mapToDouble
(IntToDoubleFunction mapper) IntermediateLongCacheStream.mapToDouble
(LongToDoubleFunction mapper) IntermediateDoubleCacheStream.parallel()
DistributedDoubleCacheStream.parallelDistribution()
IntermediateDoubleCacheStream.parallelDistribution()
DistributedDoubleCacheStream.peek
(DoubleConsumer action) DistributedDoubleCacheStream.peek
(SerializableDoubleConsumer action) IntermediateDoubleCacheStream.peek
(DoubleConsumer action) DistributedDoubleCacheStream.segmentCompletionListener
(BaseCacheStream.SegmentCompletionListener listener) IntermediateDoubleCacheStream.segmentCompletionListener
(BaseCacheStream.SegmentCompletionListener listener) IntermediateDoubleCacheStream.sequential()
DistributedDoubleCacheStream.sequentialDistribution()
IntermediateDoubleCacheStream.sequentialDistribution()
DistributedDoubleCacheStream.skip
(long n) IntermediateDoubleCacheStream.skip
(long n) DistributedDoubleCacheStream.sorted()
IntermediateDoubleCacheStream.sorted()
IntermediateDoubleCacheStream.unordered()
protected DoubleCacheStream
DistributedDoubleCacheStream.unwrap()
-
Uses of DoubleCacheStream in org.infinispan.util
Modifier and TypeMethodDescriptionAbstractDelegatingCacheStream.flatMapToDouble
(Function<? super R, ? extends DoubleStream> mapper) AbstractDelegatingCacheStream.mapToDouble
(ToDoubleFunction<? super R> mapper)