org.infinispan.stream.impl

Class IntermediateDoubleCacheStream

java.lang.Object

org.infinispan.stream.impl.IntermediateDoubleCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Double,DoubleStream>, DoubleStream, BaseCacheStream<Double,DoubleStream>, DoubleCacheStream

public class IntermediateDoubleCacheStream
extends Object
implements DoubleCacheStream

An intermediate double cache stream used when an intermediate operation that requires both a remote and local portion

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.DoubleStream

DoubleStream.Builder

Nested classes/interfaces inherited from interface org.infinispan.BaseCacheStream

BaseCacheStream.SegmentCompletionListener

Constructor Summary

Constructors

Constructor and Description
IntermediateDoubleCacheStream(BaseCacheStream remoteStream, IntermediateType type, LocalDoubleCacheStream localDoubleStream, org.infinispan.stream.impl.IntermediateCacheStreamSupplier supplier)
IntermediateDoubleCacheStream(DistributedDoubleCacheStream remoteStream)

Method Summary

Modifier and Type	Method and Description
boolean	allMatch(DoublePredicate predicate)
boolean	anyMatch(DoublePredicate predicate)
OptionalDouble	average()
CacheStream<Double>	boxed()
void	close()
<R> R	collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)
long	count()
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)
DoubleCacheStream	filterKeys(Set<?> keys) Filters which entries are returned by only returning ones that map to the given key.
DoubleCacheStream	filterKeySegments(IntSet segments) Filters which entries are returned by what segment they are present in.
DoubleCacheStream	filterKeySegments(Set<Integer> segments) Filters which entries are returned by what segment they are present in.
OptionalDouble	findAny()
OptionalDouble	findFirst()
DoubleCacheStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)
void	forEach(DoubleConsumer action)
<K,V> void	forEach(ObjDoubleConsumer<Cache<K,V>> action) Same as DoubleStream.forEach(DoubleConsumer) except that it takes an ObjDoubleConsumer that provides access to the underlying Cache that is backing this stream.
void	forEachOrdered(DoubleConsumer action)
boolean	isParallel()
PrimitiveIterator.OfDouble	iterator()
DoubleCacheStream	limit(long maxSize)
DoubleCacheStream	map(DoubleUnaryOperator mapper)
IntCacheStream	mapToInt(DoubleToIntFunction mapper)
LongCacheStream	mapToLong(DoubleToLongFunction mapper)
<U> CacheStream<U>	mapToObj(DoubleFunction<? extends U> mapper)
OptionalDouble	max()
OptionalDouble	min()
boolean	noneMatch(DoublePredicate predicate)
DoubleCacheStream	onClose(Runnable closeHandler)
DoubleCacheStream	parallel()
DoubleCacheStream	parallelDistribution() This would enable sending requests to all other remote nodes when a terminal operator is performed.
DoubleCacheStream	peek(DoubleConsumer action)
OptionalDouble	reduce(DoubleBinaryOperator op)
double	reduce(double identity, DoubleBinaryOperator op)
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()
Spliterator.OfDouble	spliterator()
double	sum()
DoubleSummaryStatistics	summaryStatistics()
DoubleCacheStream	timeout(long timeout, TimeUnit unit) Sets a given time to wait for a remote operation to respond by.
double[]	toArray()
DoubleCacheStream	unordered()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.DoubleCacheStream

allMatch, anyMatch, collect, filter, flatMap, forEach, forEach, map, mapToInt, mapToLong, mapToObj, noneMatch, peek, reduce, reduce

Methods inherited from interface java.util.stream.DoubleStream

builder, concat, empty, generate, iterate, of, of

Constructor Detail

IntermediateDoubleCacheStream

public IntermediateDoubleCacheStream(DistributedDoubleCacheStream remoteStream)

IntermediateDoubleCacheStream

public IntermediateDoubleCacheStream(BaseCacheStream remoteStream,
                                     IntermediateType type,
                                     LocalDoubleCacheStream localDoubleStream,
                                     org.infinispan.stream.impl.IntermediateCacheStreamSupplier supplier)

Method Detail

sequentialDistribution

public DoubleCacheStream sequentialDistribution()

Description copied from interface: DoubleCacheStream

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() and CacheStream.spliterator()

Specified by:

sequentialDistribution in interface BaseCacheStream<Double,DoubleStream>

Specified by:

sequentialDistribution in interface DoubleCacheStream

Returns:

a stream with parallel distribution disabled.

parallelDistribution

public DoubleCacheStream parallelDistribution()

Description copied from interface: BaseCacheStream

This 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() and CacheStream.spliterator()

Specified by:

parallelDistribution in interface BaseCacheStream<Double,DoubleStream>

Specified by:

parallelDistribution in interface DoubleCacheStream

Returns:

a stream with parallel distribution enabled.

filterKeySegments

public DoubleCacheStream filterKeySegments(Set<Integer> segments)

Description copied from interface: DoubleCacheStream

Filters which entries are returned by what segment they are present in. This method can be substantially more efficient than using a regular CacheStream.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:

filterKeySegments in interface BaseCacheStream<Double,DoubleStream>

Specified by:

filterKeySegments in interface DoubleCacheStream

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.

filterKeySegments

public DoubleCacheStream filterKeySegments(IntSet segments)

Description copied from interface: BaseCacheStream

Filters which entries are returned by what segment they are present in. This method can be substantially more efficient than using a regular CacheStream.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:

filterKeySegments in interface BaseCacheStream<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

public DoubleCacheStream filterKeys(Set<?> keys)

Description copied from interface: DoubleCacheStream

Filters which entries are returned by only returning ones that map to the given key. This method will be faster than a regular CacheStream.filter(Predicate) if the filter is holding references to the same keys.

Specified by:

filterKeys in interface BaseCacheStream<Double,DoubleStream>

Specified by:

filterKeys in interface DoubleCacheStream

Parameters:

keys - The keys that this stream will only operate on.

Returns:

a stream with the keys filtered.

distributedBatchSize

public DoubleCacheStream distributedBatchSize(int batchSize)

Description copied from interface: DoubleCacheStream

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 are CacheStream.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:

distributedBatchSize in interface BaseCacheStream<Double,DoubleStream>

Specified by:

distributedBatchSize in interface DoubleCacheStream

Parameters:

batchSize - The size of each batch. This defaults to the state transfer chunk size.

Returns:

a stream with the batch size updated

segmentCompletionListener

public DoubleCacheStream segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener)

Description copied from interface: DoubleCacheStream

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 see CacheStream.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:

segmentCompletionListener in interface BaseCacheStream<Double,DoubleStream>

Specified by:

segmentCompletionListener in interface DoubleCacheStream

Parameters:

listener - The listener that will be called back as segments are completed.

Returns:

a stream with the listener registered.

disableRehashAware

public DoubleCacheStream disableRehashAware()

Description copied from interface: DoubleCacheStream

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:

disableRehashAware in interface BaseCacheStream<Double,DoubleStream>

Specified by:

disableRehashAware in interface DoubleCacheStream

Returns:

a stream with rehash awareness disabled.

timeout

public DoubleCacheStream timeout(long timeout,
                                 TimeUnit unit)

Description copied from interface: DoubleCacheStream

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 TimeoutException is thrown from the terminal operation invoking thread or on the next call to the Iterator or Spliterator.

Note that if a rehash occurs this timeout value is reset for the subsequent retry if rehash aware is enabled.

Specified by:

timeout in interface BaseCacheStream<Double,DoubleStream>

Specified by:

timeout in interface DoubleCacheStream

Parameters:

timeout - the maximum time to wait

unit - the time unit of the timeout argument

Returns:

a stream with the timeout set

isParallel

public boolean isParallel()

Specified by:

isParallel in interface BaseStream<Double,DoubleStream>

sorted

public DoubleCacheStream sorted()

Description copied from interface: DoubleCacheStream

Specified by:

sorted in interface DoubleStream

Specified by:

sorted in interface DoubleCacheStream

Returns:

the new cache double stream

limit

public DoubleCacheStream limit(long maxSize)

Description copied from interface: DoubleCacheStream

Specified by:

limit in interface DoubleStream

Specified by:

limit in interface DoubleCacheStream

Returns:

the new cache double stream

skip

public DoubleCacheStream skip(long n)

Description copied from interface: DoubleCacheStream

Specified by:

skip in interface DoubleStream

Specified by:

skip in interface DoubleCacheStream

Returns:

the new cache double stream

peek

public DoubleCacheStream peek(DoubleConsumer action)

Description copied from interface: DoubleCacheStream

Specified by:

peek in interface DoubleStream

Specified by:

peek in interface DoubleCacheStream

Returns:

the new cache double stream

distinct

public DoubleCacheStream distinct()

Description copied from interface: DoubleCacheStream

Specified by:

distinct in interface DoubleStream

Specified by:

distinct in interface DoubleCacheStream

Returns:

the new cache double stream

filter

public DoubleCacheStream filter(DoublePredicate predicate)

Description copied from interface: DoubleCacheStream

Specified by:

filter in interface DoubleStream

Specified by:

filter in interface DoubleCacheStream

Returns:

the new cache double stream

map

public DoubleCacheStream map(DoubleUnaryOperator mapper)

Description copied from interface: DoubleCacheStream

Specified by:

map in interface DoubleStream

Specified by:

map in interface DoubleCacheStream

Returns:

the new cache double stream

mapToObj

public <U> CacheStream<U> mapToObj(DoubleFunction<? extends U> mapper)

Description copied from interface: DoubleCacheStream

Specified by:

mapToObj in interface DoubleStream

Specified by:

mapToObj in interface DoubleCacheStream

Returns:

the new cache stream

mapToInt

public IntCacheStream mapToInt(DoubleToIntFunction mapper)

Description copied from interface: DoubleCacheStream

Specified by:

mapToInt in interface DoubleStream

Specified by:

mapToInt in interface DoubleCacheStream

Returns:

the new cache int stream

mapToLong

public LongCacheStream mapToLong(DoubleToLongFunction mapper)

Description copied from interface: DoubleCacheStream

Specified by:

mapToLong in interface DoubleStream

Specified by:

mapToLong in interface DoubleCacheStream

Returns:

the new cache long stream

flatMap

public DoubleCacheStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

Description copied from interface: DoubleCacheStream

Specified by:

flatMap in interface DoubleStream

Specified by:

flatMap in interface DoubleCacheStream

Returns:

the new cache double stream

parallel

public DoubleCacheStream parallel()

Description copied from interface: DoubleCacheStream

Specified by:

parallel in interface BaseStream<Double,DoubleStream>

Specified by:

parallel in interface DoubleStream

Specified by:

parallel in interface DoubleCacheStream

Returns:

a parallel cache double stream

iterator

public PrimitiveIterator.OfDouble iterator()

Specified by:

iterator in interface BaseStream<Double,DoubleStream>

Specified by:

iterator in interface DoubleStream

spliterator

public Spliterator.OfDouble spliterator()

Specified by:

spliterator in interface BaseStream<Double,DoubleStream>

Specified by:

spliterator in interface DoubleStream

sequential

public DoubleCacheStream sequential()

Description copied from interface: DoubleCacheStream

Specified by:

sequential in interface BaseStream<Double,DoubleStream>

Specified by:

sequential in interface DoubleStream

Specified by:

sequential in interface DoubleCacheStream

Returns:

a sequential cache double stream

unordered

public DoubleCacheStream unordered()

Description copied from interface: DoubleCacheStream

Specified by:

unordered in interface BaseStream<Double,DoubleStream>

Specified by:

unordered in interface DoubleCacheStream

Returns:

an unordered cache double stream

forEach

public void forEach(DoubleConsumer action)

Specified by:

forEach in interface DoubleStream

forEach

public <K,V> void forEach(ObjDoubleConsumer<Cache<K,V>> action)

Description copied from interface: DoubleCacheStream

Same as DoubleStream.forEach(DoubleConsumer) except that it takes an ObjDoubleConsumer that provides access to the underlying Cache that is backing this stream.

Note that the CacheAware interface is not supported for injection using this method as the cache is provided in the consumer directly.

Specified by:

forEach in interface DoubleCacheStream

Type Parameters:

K - key type of the cache

V - value type of the cache

Parameters:

action - consumer to be ran for each element in the stream

forEachOrdered

public void forEachOrdered(DoubleConsumer action)

Specified by:

forEachOrdered in interface DoubleStream

toArray

public double[] toArray()

Specified by:

toArray in interface DoubleStream

reduce

public double reduce(double identity,
                     DoubleBinaryOperator op)

Specified by:

reduce in interface DoubleStream

reduce

public OptionalDouble reduce(DoubleBinaryOperator op)

Specified by:

reduce in interface DoubleStream

collect

public <R> R collect(Supplier<R> supplier,
                     ObjDoubleConsumer<R> accumulator,
                     BiConsumer<R,R> combiner)

Specified by:

collect in interface DoubleStream

sum

public double sum()

Specified by:

sum in interface DoubleStream

min

public OptionalDouble min()

Specified by:

min in interface DoubleStream

max

public OptionalDouble max()

Specified by:

max in interface DoubleStream

count

public long count()

Specified by:

count in interface DoubleStream

average

public OptionalDouble average()

Specified by:

average in interface DoubleStream

summaryStatistics

public DoubleSummaryStatistics summaryStatistics()

Specified by:

summaryStatistics in interface DoubleStream

anyMatch

public boolean anyMatch(DoublePredicate predicate)

Specified by:

anyMatch in interface DoubleStream

allMatch

public boolean allMatch(DoublePredicate predicate)

Specified by:

allMatch in interface DoubleStream

noneMatch

public boolean noneMatch(DoublePredicate predicate)

Specified by:

noneMatch in interface DoubleStream

findFirst

public OptionalDouble findFirst()

Specified by:

findFirst in interface DoubleStream

findAny

public OptionalDouble findAny()

Specified by:

findAny in interface DoubleStream

boxed

public CacheStream<Double> boxed()

Description copied from interface: DoubleCacheStream

Specified by:

boxed in interface DoubleStream

Specified by:

boxed in interface DoubleCacheStream

Returns:

the new cache stream containing doubles

onClose

public DoubleCacheStream onClose(Runnable closeHandler)

Description copied from interface: DoubleCacheStream

Specified by:

onClose in interface BaseStream<Double,DoubleStream>

Specified by:

onClose in interface DoubleCacheStream

Returns:

a cache double stream with the handler applied

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BaseStream<Double,DoubleStream>