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.

Uses of DoubleCacheStream in org.infinispan

Methods in org.infinispan that return DoubleCacheStream

Modifier and Type	Method and Description
DoubleCacheStream	LongCacheStream.asDoubleStream()
DoubleCacheStream	IntCacheStream.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()