Uses of Interface
org.infinispan.DoubleCacheStream
-
Packages that use DoubleCacheStream Package Description org.infinispan This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.org.infinispan.stream.impl org.infinispan.util 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
Methods in org.infinispan that return DoubleCacheStream Modifier and Type Method Description DoubleCacheStream
IntCacheStream. asDoubleStream()
DoubleCacheStream
LongCacheStream. asDoubleStream()
DoubleCacheStream
DoubleCacheStream. disableRehashAware()
Disables tracking of rehash events that could occur to the underlying cache.DoubleCacheStream
DoubleCacheStream. distinct()
DoubleCacheStream
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
DoubleCacheStream. filter(DoublePredicate predicate)
default DoubleCacheStream
DoubleCacheStream. filter(SerializableDoublePredicate predicate)
Same asfilter(DoublePredicate)
except that the DoublePredicate must also implementSerializable
DoubleCacheStream
DoubleCacheStream. filterKeys(Set<?> keys)
Filters which entries are returned by only returning ones that map to the given key.DoubleCacheStream
DoubleCacheStream. filterKeySegments(Set<Integer> segments)
Filters which entries are returned by what segment they are present in.DoubleCacheStream
DoubleCacheStream. flatMap(DoubleFunction<? extends DoubleStream> mapper)
default DoubleCacheStream
DoubleCacheStream. flatMap(SerializableDoubleFunction<? extends DoubleStream> mapper)
Same asflatMap(DoubleFunction)
except that the DoubleFunction must also implementSerializable
DoubleCacheStream
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
DoubleCacheStream. limit(long maxSize)
DoubleCacheStream
DoubleCacheStream. map(DoubleUnaryOperator mapper)
default DoubleCacheStream
DoubleCacheStream. map(SerializableDoubleUnaryOperator mapper)
Same asmap(DoubleUnaryOperator)
except that the DoubleUnaryOperator must also implementSerializable
DoubleCacheStream
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
DoubleCacheStream
IntCacheStream. mapToDouble(IntToDoubleFunction mapper)
default DoubleCacheStream
IntCacheStream. mapToDouble(SerializableIntToDoubleFunction mapper)
Same asIntCacheStream.mapToDouble(IntToDoubleFunction)
except that the IntToIntFunction must also implementSerializable
DoubleCacheStream
LongCacheStream. mapToDouble(LongToDoubleFunction mapper)
default DoubleCacheStream
LongCacheStream. mapToDouble(SerializableLongToDoubleFunction mapper)
Same asLongCacheStream.mapToDouble(LongToDoubleFunction)
except that the LongToLongFunction must also implement Serializable.DoubleCacheStream
DoubleCacheStream. onClose(Runnable closeHandler)
DoubleCacheStream
DoubleCacheStream. parallel()
DoubleCacheStream
DoubleCacheStream. parallelDistribution()
DoubleCacheStream
DoubleCacheStream. peek(DoubleConsumer action)
default DoubleCacheStream
DoubleCacheStream. peek(SerializableDoubleConsumer action)
Same asflatMap(DoubleFunction)
except that the DoubleFunction must also implementSerializable
DoubleCacheStream
DoubleCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
Allows registration of a segment completion listener that is notified when a segment has completed processing.DoubleCacheStream
DoubleCacheStream. sequential()
DoubleCacheStream
DoubleCacheStream. sequentialDistribution()
This would disable sending requests to all other remote nodes compared to one at a time.DoubleCacheStream
DoubleCacheStream. skip(long n)
DoubleCacheStream
DoubleCacheStream. sorted()
DoubleCacheStream
DoubleCacheStream. timeout(long timeout, TimeUnit unit)
Sets a given time to wait for a remote operation to respond by.DoubleCacheStream
DoubleCacheStream. unordered()
-
Uses of DoubleCacheStream in org.infinispan.stream.impl
Classes in org.infinispan.stream.impl that implement DoubleCacheStream Modifier and Type Class Description class
DistributedDoubleCacheStream<Original>
Implementation ofDoubleStream
that utilizes a lazily evaluated distributed back end execution.class
IntermediateDoubleCacheStream
An intermediate double cache stream used when an intermediate operation that requires both a remote and local portionMethods in org.infinispan.stream.impl that return DoubleCacheStream Modifier and Type Method Description DoubleCacheStream
DistributedIntCacheStream. asDoubleStream()
DoubleCacheStream
DistributedLongCacheStream. asDoubleStream()
DoubleCacheStream
IntermediateIntCacheStream. asDoubleStream()
DoubleCacheStream
IntermediateLongCacheStream. asDoubleStream()
DoubleCacheStream
DistributedDoubleCacheStream. disableRehashAware()
DoubleCacheStream
IntermediateDoubleCacheStream. disableRehashAware()
DoubleCacheStream
DistributedDoubleCacheStream. distinct()
DoubleCacheStream
IntermediateDoubleCacheStream. distinct()
DoubleCacheStream
DistributedDoubleCacheStream. distributedBatchSize(int batchSize)
DoubleCacheStream
IntermediateDoubleCacheStream. distributedBatchSize(int batchSize)
DoubleCacheStream
DistributedDoubleCacheStream. filter(DoublePredicate predicate)
DoubleCacheStream
DistributedDoubleCacheStream. filter(SerializableDoublePredicate predicate)
DoubleCacheStream
IntermediateDoubleCacheStream. filter(DoublePredicate predicate)
DoubleCacheStream
DistributedDoubleCacheStream. filterKeys(Set<?> keys)
DoubleCacheStream
IntermediateDoubleCacheStream. filterKeys(Set<?> keys)
DoubleCacheStream
DistributedDoubleCacheStream. filterKeySegments(Set<Integer> segments)
DoubleCacheStream
DistributedDoubleCacheStream. filterKeySegments(org.infinispan.commons.util.IntSet segments)
DoubleCacheStream
IntermediateDoubleCacheStream. filterKeySegments(Set<Integer> segments)
DoubleCacheStream
IntermediateDoubleCacheStream. filterKeySegments(org.infinispan.commons.util.IntSet segments)
DoubleCacheStream
DistributedDoubleCacheStream. flatMap(DoubleFunction<? extends DoubleStream> mapper)
DoubleCacheStream
DistributedDoubleCacheStream. flatMap(SerializableDoubleFunction<? extends DoubleStream> mapper)
DoubleCacheStream
IntermediateDoubleCacheStream. flatMap(DoubleFunction<? extends DoubleStream> mapper)
DoubleCacheStream
DistributedCacheStream. flatMapToDouble(Function<? super R,? extends DoubleStream> mapper)
DoubleCacheStream
IntermediateCacheStream. flatMapToDouble(Function<? super R,? extends DoubleStream> mapper)
DoubleCacheStream
DistributedDoubleCacheStream. limit(long maxSize)
DoubleCacheStream
IntermediateDoubleCacheStream. limit(long maxSize)
DoubleCacheStream
DistributedDoubleCacheStream. map(DoubleUnaryOperator mapper)
DoubleCacheStream
DistributedDoubleCacheStream. map(SerializableDoubleUnaryOperator mapper)
DoubleCacheStream
IntermediateDoubleCacheStream. map(DoubleUnaryOperator mapper)
DoubleCacheStream
DistributedCacheStream. mapToDouble(ToDoubleFunction<? super R> mapper)
DoubleCacheStream
DistributedIntCacheStream. mapToDouble(IntToDoubleFunction mapper)
DoubleCacheStream
DistributedIntCacheStream. mapToDouble(SerializableIntToDoubleFunction mapper)
DoubleCacheStream
DistributedLongCacheStream. mapToDouble(LongToDoubleFunction mapper)
DoubleCacheStream
DistributedLongCacheStream. mapToDouble(SerializableLongToDoubleFunction mapper)
DoubleCacheStream
IntermediateCacheStream. mapToDouble(ToDoubleFunction<? super R> mapper)
DoubleCacheStream
IntermediateIntCacheStream. mapToDouble(IntToDoubleFunction mapper)
DoubleCacheStream
IntermediateLongCacheStream. mapToDouble(LongToDoubleFunction mapper)
DoubleCacheStream
IntermediateDoubleCacheStream. onClose(Runnable closeHandler)
DoubleCacheStream
IntermediateDoubleCacheStream. parallel()
DoubleCacheStream
DistributedDoubleCacheStream. parallelDistribution()
DoubleCacheStream
IntermediateDoubleCacheStream. parallelDistribution()
DoubleCacheStream
DistributedDoubleCacheStream. peek(DoubleConsumer action)
DoubleCacheStream
DistributedDoubleCacheStream. peek(SerializableDoubleConsumer action)
DoubleCacheStream
IntermediateDoubleCacheStream. peek(DoubleConsumer action)
DoubleCacheStream
DistributedDoubleCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
DoubleCacheStream
IntermediateDoubleCacheStream. segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
DoubleCacheStream
IntermediateDoubleCacheStream. sequential()
DoubleCacheStream
DistributedDoubleCacheStream. sequentialDistribution()
DoubleCacheStream
IntermediateDoubleCacheStream. sequentialDistribution()
DoubleCacheStream
DistributedDoubleCacheStream. skip(long n)
DoubleCacheStream
IntermediateDoubleCacheStream. skip(long n)
DoubleCacheStream
DistributedDoubleCacheStream. sorted()
DoubleCacheStream
IntermediateDoubleCacheStream. sorted()
DoubleCacheStream
DistributedDoubleCacheStream. timeout(long timeout, TimeUnit unit)
DoubleCacheStream
IntermediateDoubleCacheStream. timeout(long timeout, TimeUnit unit)
DoubleCacheStream
IntermediateDoubleCacheStream. unordered()
protected DoubleCacheStream
DistributedDoubleCacheStream. unwrap()
-
Uses of DoubleCacheStream in org.infinispan.util
Methods in org.infinispan.util that return DoubleCacheStream Modifier and Type Method Description DoubleCacheStream
AbstractDelegatingCacheStream. flatMapToDouble(Function<? super R,? extends DoubleStream> mapper)
DoubleCacheStream
AbstractDelegatingCacheStream. mapToDouble(ToDoubleFunction<? super R> mapper)
-