Interface DoubleCacheStream
-
- All Superinterfaces:
AutoCloseable,BaseCacheStream<Double,DoubleStream>,BaseStream<Double,DoubleStream>,DoubleStream
public interface DoubleCacheStream extends DoubleStream, BaseCacheStream<Double,DoubleStream>
ADoubleStreamthat has additional methods to allow for Serializable instances. Please seeCacheStreamfor additional details about various methods.- Since:
- 9.0
- Author:
- wburns
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.infinispan.BaseCacheStream
BaseCacheStream.SegmentCompletionListener
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description default booleanallMatch(org.infinispan.util.function.SerializableDoublePredicate predicate)Same asDoubleStream.allMatch(DoublePredicate)except that the DoublePredicate must also implementSerializabledefault booleananyMatch(org.infinispan.util.function.SerializableDoublePredicate predicate)Same asDoubleStream.anyMatch(DoublePredicate)except that the DoublePredicate must also implementSerializableCacheStream<Double>boxed()default <R> Rcollect(org.infinispan.util.function.SerializableSupplier<R> supplier, org.infinispan.util.function.SerializableObjDoubleConsumer<R> accumulator, org.infinispan.util.function.SerializableBiConsumer<R,R> combiner)Same asDoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer)except that the arguments must also implementSerializableDoubleCacheStreamdisableRehashAware()Disables tracking of rehash events that could occur to the underlying cache.DoubleCacheStreamdistinct()DoubleCacheStreamdistributedBatchSize(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.DoubleCacheStreamfilter(DoublePredicate predicate)default DoubleCacheStreamfilter(org.infinispan.util.function.SerializableDoublePredicate predicate)Same asfilter(DoublePredicate)except that the DoublePredicate must also implementSerializableDoubleCacheStreamfilterKeys(Set<?> keys)Filters which entries are returned by only returning ones that map to the given key.DoubleCacheStreamfilterKeySegments(Set<Integer> segments)Filters which entries are returned by what segment they are present in.DoubleCacheStreamflatMap(DoubleFunction<? extends DoubleStream> mapper)default DoubleCacheStreamflatMap(org.infinispan.util.function.SerializableDoubleFunction<? extends DoubleStream> mapper)Same asflatMap(DoubleFunction)except that the DoubleFunction must also implementSerializable<K,V>
voidforEach(ObjDoubleConsumer<Cache<K,V>> action)Same asDoubleStream.forEach(DoubleConsumer)except that it takes anObjDoubleConsumerthat provides access to the underlyingCachethat is backing this stream.default voidforEach(org.infinispan.util.function.SerializableDoubleConsumer action)Same asDoubleStream.forEach(DoubleConsumer)except that the DoubleConsumer must also implementSerializabledefault <K,V>
voidforEach(org.infinispan.util.function.SerializableObjDoubleConsumer<Cache<K,V>> action)DoubleCacheStreamlimit(long maxSize)DoubleCacheStreammap(DoubleUnaryOperator mapper)default DoubleCacheStreammap(org.infinispan.util.function.SerializableDoubleUnaryOperator mapper)Same asmap(DoubleUnaryOperator)except that the DoubleUnaryOperator must also implementSerializableIntCacheStreammapToInt(DoubleToIntFunction mapper)default IntCacheStreammapToInt(org.infinispan.util.function.SerializableDoubleToIntFunction mapper)Same asmapToInt(DoubleToIntFunction)except that the DoubleToIntFunction must also implementSerializableLongCacheStreammapToLong(DoubleToLongFunction mapper)default LongCacheStreammapToLong(org.infinispan.util.function.SerializableDoubleToLongFunction mapper)Same asmapToLong(DoubleToLongFunction)except that the DoubleToLongFunction must also implementSerializable<U> CacheStream<U>mapToObj(DoubleFunction<? extends U> mapper)default <U> CacheStream<U>mapToObj(org.infinispan.util.function.SerializableDoubleFunction<? extends U> mapper)Same asmapToObj(DoubleFunction)except that the DoubleFunction must also implementSerializabledefault booleannoneMatch(org.infinispan.util.function.SerializableDoublePredicate predicate)Same asDoubleStream.noneMatch(DoublePredicate)except that the DoublePredicate must also implementSerializableDoubleCacheStreamonClose(Runnable closeHandler)DoubleCacheStreamparallel()DoubleCacheStreamparallelDistribution()This would enable sending requests to all other remote nodes when a terminal operator is performed.DoubleCacheStreampeek(DoubleConsumer action)default DoubleCacheStreampeek(org.infinispan.util.function.SerializableDoubleConsumer action)Same asflatMap(DoubleFunction)except that the DoubleFunction must also implementSerializabledefault doublereduce(double identity, org.infinispan.util.function.SerializableDoubleBinaryOperator op)Same asDoubleStream.reduce(double, DoubleBinaryOperator)except that the DoubleBinaryOperator must also implementSerializabledefault OptionalDoublereduce(org.infinispan.util.function.SerializableDoubleBinaryOperator op)Same asDoubleStream.reduce(DoubleBinaryOperator)except that the DoubleBinaryOperator must also implementSerializableDoubleCacheStreamsegmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)Allows registration of a segment completion listener that is notified when a segment has completed processing.DoubleCacheStreamsequential()DoubleCacheStreamsequentialDistribution()This would disable sending requests to all other remote nodes compared to one at a time.DoubleCacheStreamskip(long n)DoubleCacheStreamsorted()DoubleCacheStreamtimeout(long timeout, TimeUnit unit)Sets a given time to wait for a remote operation to respond by.DoubleCacheStreamunordered()-
Methods inherited from interface org.infinispan.BaseCacheStream
filterKeySegments
-
-
-
-
Method Detail
-
sequentialDistribution
DoubleCacheStream sequentialDistribution()
This would disable sending requests to all other remote nodes compared to one at a time. This can reduce memory pressure on the originator node at the cost of performance.Parallel distribution is enabled by default except for
CacheStream.iterator()andCacheStream.spliterator()- Specified by:
sequentialDistributionin interfaceBaseCacheStream<Double,DoubleStream>- Returns:
- a stream with parallel distribution disabled.
-
parallelDistribution
DoubleCacheStream parallelDistribution()
Description copied from interface:BaseCacheStreamThis would enable sending requests to all other remote nodes when a terminal operator is performed. This requires additional overhead as it must process results concurrently from various nodes, but should perform faster in the majority of cases.Parallel distribution is enabled by default except for
CacheStream.iterator()andCacheStream.spliterator()- Specified by:
parallelDistributionin interfaceBaseCacheStream<Double,DoubleStream>- Returns:
- a stream with parallel distribution enabled.
-
filterKeySegments
DoubleCacheStream filterKeySegments(Set<Integer> segments)
Filters which entries are returned by what segment they are present in. This method can be substantially more efficient than using a regularCacheStream.filter(Predicate)method as this can control what nodes are asked for data and what entries are read from the underlying CacheStore if present.- Specified by:
filterKeySegmentsin interfaceBaseCacheStream<Double,DoubleStream>- Parameters:
segments- The segments to use for this stream operation. Any segments not in this set will be ignored.- Returns:
- a stream with the segments filtered.
-
filterKeys
DoubleCacheStream filterKeys(Set<?> keys)
Filters which entries are returned by only returning ones that map to the given key. This method will be faster than a regularCacheStream.filter(Predicate)if the filter is holding references to the same keys.- Specified by:
filterKeysin interfaceBaseCacheStream<Double,DoubleStream>- Parameters:
keys- The keys that this stream will only operate on.- Returns:
- a stream with the keys filtered.
-
distributedBatchSize
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. This value is ignored when terminal operators that don't track keys are used. Key tracking terminal operators areCacheStream.iterator(),CacheStream.spliterator(),CacheStream.forEach(Consumer). Please see those methods for additional information on how this value may affect them.This value may be used in the case of a a terminal operator that doesn't track keys if an intermediate operation is performed that requires bringing keys locally to do computations. Examples of such intermediate operations are
CacheStream.sorted(),CacheStream.sorted(Comparator),CacheStream.distinct(),CacheStream.limit(long),CacheStream.skip(long)This value is always ignored when this stream is backed by a cache that is not distributed as all values are already local.
- Specified by:
distributedBatchSizein interfaceBaseCacheStream<Double,DoubleStream>- Parameters:
batchSize- The size of each batch. This defaults to the state transfer chunk size.- Returns:
- a stream with the batch size updated
-
segmentCompletionListener
DoubleCacheStream segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)
Allows registration of a segment completion listener that is notified when a segment has completed processing. If the terminal operator has a short circuit this listener may never be called.This method is designed for the sole purpose of use with the
CacheStream.iterator()to allow for a user to track completion of segments as they are returned from the iterator. Behavior of other methods is not specified. Please seeCacheStream.iterator()for more information.Multiple listeners may be registered upon multiple invocations of this method. The ordering of notified listeners is not specified.
This is only used if this stream did not invoke
BaseCacheStream.disableRehashAware()and has no flat map based operations. If this is done no segments will be notified.- Specified by:
segmentCompletionListenerin interfaceBaseCacheStream<Double,DoubleStream>- Parameters:
listener- The listener that will be called back as segments are completed.- Returns:
- a stream with the listener registered.
-
disableRehashAware
DoubleCacheStream disableRehashAware()
Disables tracking of rehash events that could occur to the underlying cache. If a rehash event occurs while a terminal operation is being performed it is possible for some values that are in the cache to not be found. Note that you will never have an entry duplicated when rehash awareness is disabled, only lost values.Most terminal operations will run faster with rehash awareness disabled even without a rehash occuring. However if a rehash occurs with this disabled be prepared to possibly receive only a subset of values.
- Specified by:
disableRehashAwarein interfaceBaseCacheStream<Double,DoubleStream>- Returns:
- a stream with rehash awareness disabled.
-
timeout
DoubleCacheStream timeout(long timeout, TimeUnit unit)
Sets a given time to wait for a remote operation to respond by. This timeout does nothing if the terminal operation does not go remote.If a timeout does occur then a
TimeoutExceptionis thrown from the terminal operation invoking thread or on the next call to theIteratororSpliterator.Note that if a rehash occurs this timeout value is reset for the subsequent retry if rehash aware is enabled.
- Specified by:
timeoutin interfaceBaseCacheStream<Double,DoubleStream>- Parameters:
timeout- the maximum time to waitunit- the time unit of the timeout argument- Returns:
- a stream with the timeout set
-
filter
DoubleCacheStream filter(DoublePredicate predicate)
- Returns:
- the new cache double stream
-
filter
default DoubleCacheStream filter(org.infinispan.util.function.SerializableDoublePredicate predicate)
Same asfilter(DoublePredicate)except that the DoublePredicate must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
predicate- a non-interfering, stateless predicate to apply to each element to determine if it should be included- Returns:
- the new cache double stream
-
map
DoubleCacheStream map(DoubleUnaryOperator mapper)
- Returns:
- the new cache double stream
-
map
default DoubleCacheStream map(org.infinispan.util.function.SerializableDoubleUnaryOperator mapper)
Same asmap(DoubleUnaryOperator)except that the DoubleUnaryOperator must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
mapper- a non-interfering, stateless function to apply to each element- Returns:
- the new cache double stream
-
mapToObj
<U> CacheStream<U> mapToObj(DoubleFunction<? extends U> mapper)
- Returns:
- the new cache stream
-
mapToObj
default <U> CacheStream<U> mapToObj(org.infinispan.util.function.SerializableDoubleFunction<? extends U> mapper)
Same asmapToObj(DoubleFunction)except that the DoubleFunction must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Type Parameters:
U- the element type of the new stream- Parameters:
mapper- a non-interfering, stateless function to apply to each element- Returns:
- the new cache stream
-
mapToInt
IntCacheStream mapToInt(DoubleToIntFunction mapper)
- Returns:
- the new cache int stream
-
mapToInt
default IntCacheStream mapToInt(org.infinispan.util.function.SerializableDoubleToIntFunction mapper)
Same asmapToInt(DoubleToIntFunction)except that the DoubleToIntFunction must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
mapper- a non-interfering, stateless function to apply to each element- Returns:
- the new cache int stream
-
mapToLong
LongCacheStream mapToLong(DoubleToLongFunction mapper)
- Returns:
- the new cache long stream
-
mapToLong
default LongCacheStream mapToLong(org.infinispan.util.function.SerializableDoubleToLongFunction mapper)
Same asmapToLong(DoubleToLongFunction)except that the DoubleToLongFunction must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
mapper- a non-interfering, stateless function to apply to each element- Returns:
- the new cache long stream
-
flatMap
DoubleCacheStream flatMap(DoubleFunction<? extends DoubleStream> mapper)
- Returns:
- the new cache double stream
-
flatMap
default DoubleCacheStream flatMap(org.infinispan.util.function.SerializableDoubleFunction<? extends DoubleStream> mapper)
Same asflatMap(DoubleFunction)except that the DoubleFunction must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
mapper- a non-interfering, stateless function to apply to each element which produces aDoubleStreamof new values- Returns:
- the new cache double stream
-
distinct
DoubleCacheStream distinct()
- Returns:
- the new cache double stream
-
sorted
DoubleCacheStream sorted()
- Returns:
- the new cache double stream
-
peek
DoubleCacheStream peek(DoubleConsumer action)
- Returns:
- the new cache double stream
-
peek
default DoubleCacheStream peek(org.infinispan.util.function.SerializableDoubleConsumer action)
Same asflatMap(DoubleFunction)except that the DoubleFunction must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
action- a non-interfering action to perform on the elements as they are consumed from the stream- Returns:
- the new cache double stream
-
limit
DoubleCacheStream limit(long maxSize)
- Returns:
- the new cache double stream
-
skip
DoubleCacheStream skip(long n)
- Returns:
- the new cache double stream
-
forEach
default void forEach(org.infinispan.util.function.SerializableDoubleConsumer action)
Same asDoubleStream.forEach(DoubleConsumer)except that the DoubleConsumer must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
action- a non-interfering action to perform on the elements
-
forEach
<K,V> void forEach(ObjDoubleConsumer<Cache<K,V>> action)
Same asDoubleStream.forEach(DoubleConsumer)except that it takes anObjDoubleConsumerthat provides access to the underlyingCachethat is backing this stream.Note that the
CacheAwareinterface is not supported for injection using this method as the cache is provided in the consumer directly.- Type Parameters:
K- key type of the cacheV- value type of the cache- Parameters:
action- consumer to be ran for each element in the stream
-
forEach
default <K,V> void forEach(org.infinispan.util.function.SerializableObjDoubleConsumer<Cache<K,V>> action)
- Type Parameters:
K- key type of the cacheV- value type of the cache- Parameters:
action- consumer to be ran for each element in the stream
-
reduce
default double reduce(double identity, org.infinispan.util.function.SerializableDoubleBinaryOperator op)Same asDoubleStream.reduce(double, DoubleBinaryOperator)except that the DoubleBinaryOperator must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
identity- the identity value for the accumulating functionop- an associative, non-interfering, stateless function for combining two values- Returns:
- the result of the reduction
-
reduce
default OptionalDouble reduce(org.infinispan.util.function.SerializableDoubleBinaryOperator op)
Same asDoubleStream.reduce(DoubleBinaryOperator)except that the DoubleBinaryOperator must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
op- an associative, non-interfering, stateless function for combining two values- Returns:
- the result of the reduction
-
collect
default <R> R collect(org.infinispan.util.function.SerializableSupplier<R> supplier, org.infinispan.util.function.SerializableObjDoubleConsumer<R> accumulator, org.infinispan.util.function.SerializableBiConsumer<R,R> combiner)Same asDoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer)except that the arguments must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Type Parameters:
R- type of the result- Parameters:
supplier- a function that creates a new result container. For a parallel execution, this function may be called multiple times and must return a fresh value each time.accumulator- an associative, non-interfering, stateless function for incorporating an additional element into a resultcombiner- an associative, non-interfering, stateless function for combining two values, which must be compatible with the accumulator function- Returns:
- the result of the reduction
-
anyMatch
default boolean anyMatch(org.infinispan.util.function.SerializableDoublePredicate predicate)
Same asDoubleStream.anyMatch(DoublePredicate)except that the DoublePredicate must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
predicate- a non-interfering, stateless predicate to apply to elements of this stream- Returns:
trueif any elements of the stream match the provided predicate, otherwisefalse
-
allMatch
default boolean allMatch(org.infinispan.util.function.SerializableDoublePredicate predicate)
Same asDoubleStream.allMatch(DoublePredicate)except that the DoublePredicate must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
predicate- a non-interfering, stateless predicate to apply to elements of this stream- Returns:
trueif either all elements of the stream match the provided predicate or the stream is empty, otherwisefalse
-
noneMatch
default boolean noneMatch(org.infinispan.util.function.SerializableDoublePredicate predicate)
Same asDoubleStream.noneMatch(DoublePredicate)except that the DoublePredicate must also implementSerializableThe compiler will pick this overload for lambda parameters, making them
Serializable- Parameters:
predicate- a non-interfering, stateless predicate to apply to elements of this stream- Returns:
trueif either no elements of the stream match the provided predicate or the stream is empty, otherwisefalse
-
boxed
CacheStream<Double> boxed()
- Returns:
- the new cache stream containing doubles
-
sequential
DoubleCacheStream sequential()
- Returns:
- a sequential cache double stream
-
parallel
DoubleCacheStream parallel()
- Returns:
- a parallel cache double stream
-
unordered
DoubleCacheStream unordered()
- Returns:
- an unordered cache double stream
-
onClose
DoubleCacheStream onClose(Runnable closeHandler)
- Returns:
- a cache double stream with the handler applied
-
-