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.stream.impl.local
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 and 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 as filter(DoublePredicate) except that the DoublePredicate must also implement Serializable
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 as flatMap(DoubleFunction) except that the DoubleFunction must also implement Serializable
DoubleCacheStream	CacheStream.flatMapToDouble(Function<? super R,? extends DoubleStream> mapper)
default DoubleCacheStream	CacheStream.flatMapToDouble(SerializableFunction<? super R,? extends DoubleStream> mapper) Same as CacheStream.flatMapToDouble(Function) except that the Function must also implement Serializable
DoubleCacheStream	DoubleCacheStream.limit(long maxSize)
DoubleCacheStream	DoubleCacheStream.map(DoubleUnaryOperator mapper)
default DoubleCacheStream	DoubleCacheStream.map(SerializableDoubleUnaryOperator mapper) Same as map(DoubleUnaryOperator) except that the DoubleUnaryOperator must also implement Serializable
DoubleCacheStream	IntCacheStream.mapToDouble(IntToDoubleFunction mapper)
DoubleCacheStream	LongCacheStream.mapToDouble(LongToDoubleFunction mapper)
default DoubleCacheStream	IntCacheStream.mapToDouble(SerializableIntToDoubleFunction mapper) Same as IntCacheStream.mapToDouble(IntToDoubleFunction) except that the IntToIntFunction must also implement Serializable
default DoubleCacheStream	LongCacheStream.mapToDouble(SerializableLongToDoubleFunction mapper) Same as LongCacheStream.mapToDouble(LongToDoubleFunction) except that the LongToLongFunction must also implement Serializable.
default DoubleCacheStream	CacheStream.mapToDouble(SerializableToDoubleFunction<? super R> mapper) Same as CacheStream.mapToDouble(ToDoubleFunction) except that the ToDoubleFunction must also implement Serializable
DoubleCacheStream	CacheStream.mapToDouble(ToDoubleFunction<? super R> mapper)
DoubleCacheStream	DoubleCacheStream.onClose(Runnable closeHandler)
DoubleCacheStream	DoubleCacheStream.parallel()
DoubleCacheStream	DoubleCacheStream.parallelDistribution()
DoubleCacheStream	DoubleCacheStream.peek(DoubleConsumer action)
default DoubleCacheStream	DoubleCacheStream.peek(SerializableDoubleConsumer action) Same as flatMap(DoubleFunction) except that the DoubleFunction must also implement Serializable
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 and Description
class	DistributedDoubleCacheStream<Original> Implementation of DoubleStream 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 portion

Methods in org.infinispan.stream.impl that return DoubleCacheStream

Modifier and Type	Method and 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	IntermediateDoubleCacheStream.filter(DoublePredicate predicate)
DoubleCacheStream	DistributedDoubleCacheStream.filter(SerializableDoublePredicate predicate)
DoubleCacheStream	DistributedDoubleCacheStream.filterKeys(Set<?> keys)
DoubleCacheStream	IntermediateDoubleCacheStream.filterKeys(Set<?> keys)
DoubleCacheStream	DistributedDoubleCacheStream.filterKeySegments(IntSet segments)
DoubleCacheStream	IntermediateDoubleCacheStream.filterKeySegments(IntSet segments)
DoubleCacheStream	DistributedDoubleCacheStream.filterKeySegments(Set<Integer> segments)
DoubleCacheStream	IntermediateDoubleCacheStream.filterKeySegments(Set<Integer> segments)
DoubleCacheStream	DistributedDoubleCacheStream.flatMap(DoubleFunction<? extends DoubleStream> mapper)
DoubleCacheStream	IntermediateDoubleCacheStream.flatMap(DoubleFunction<? extends DoubleStream> mapper)
DoubleCacheStream	DistributedDoubleCacheStream.flatMap(SerializableDoubleFunction<? 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	IntermediateDoubleCacheStream.map(DoubleUnaryOperator mapper)
DoubleCacheStream	DistributedDoubleCacheStream.map(SerializableDoubleUnaryOperator mapper)
DoubleCacheStream	DistributedIntCacheStream.mapToDouble(IntToDoubleFunction mapper)
DoubleCacheStream	IntermediateIntCacheStream.mapToDouble(IntToDoubleFunction mapper)
DoubleCacheStream	DistributedLongCacheStream.mapToDouble(LongToDoubleFunction mapper)
DoubleCacheStream	IntermediateLongCacheStream.mapToDouble(LongToDoubleFunction mapper)
DoubleCacheStream	DistributedIntCacheStream.mapToDouble(SerializableIntToDoubleFunction mapper)
DoubleCacheStream	DistributedLongCacheStream.mapToDouble(SerializableLongToDoubleFunction mapper)
DoubleCacheStream	DistributedCacheStream.mapToDouble(ToDoubleFunction<? super R> mapper)
DoubleCacheStream	IntermediateCacheStream.mapToDouble(ToDoubleFunction<? super R> mapper)
DoubleCacheStream	IntermediateDoubleCacheStream.onClose(Runnable closeHandler)
DoubleCacheStream	IntermediateDoubleCacheStream.parallel()
DoubleCacheStream	DistributedDoubleCacheStream.parallelDistribution()
DoubleCacheStream	IntermediateDoubleCacheStream.parallelDistribution()
DoubleCacheStream	DistributedDoubleCacheStream.peek(DoubleConsumer action)
DoubleCacheStream	IntermediateDoubleCacheStream.peek(DoubleConsumer action)
DoubleCacheStream	DistributedDoubleCacheStream.peek(SerializableDoubleConsumer 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.stream.impl.local

Classes in org.infinispan.stream.impl.local that implement DoubleCacheStream

Modifier and Type	Class and Description
class	LocalDoubleCacheStream DoubleStream that wraps a given stream to allow for additional functionality such as injection of values into various operations

Methods in org.infinispan.stream.impl.local that return DoubleCacheStream

Modifier and Type	Method and Description
DoubleCacheStream	LocalIntCacheStream.asDoubleStream()
DoubleCacheStream	LocalLongCacheStream.asDoubleStream()

Uses of DoubleCacheStream in org.infinispan.util

Methods in org.infinispan.util that return DoubleCacheStream

Modifier and Type	Method and Description
DoubleCacheStream	AbstractDelegatingCacheStream.flatMapToDouble(Function<? super R,? extends DoubleStream> mapper)
DoubleCacheStream	AbstractDelegatingCacheStream.mapToDouble(ToDoubleFunction<? super R> mapper)