Class DistributedLongCacheStream<Original>
- Type Parameters:
Original
- original stream type
- All Implemented Interfaces:
AutoCloseable
,BaseStream<Long,
,LongStream> LongStream
,BaseCacheStream<Long,
,LongStream> LongCacheStream
LongStream
that utilizes a lazily evaluated distributed back end execution. Note this
class is only able to be created using CacheStream.mapToInt(ToIntFunction)
or similar
methods from the CacheStream
interface.-
Nested Class Summary
Nested classes/interfaces inherited from interface org.infinispan.BaseCacheStream
BaseCacheStream.SegmentCompletionListener
Nested classes/interfaces inherited from interface java.util.stream.LongStream
LongStream.Builder
-
Field Summary
Fields inherited from class org.infinispan.stream.impl.AbstractCacheStream
closeRunnable, cpm, distributedBatchSize, executor, explicitFlags, intermediateOperations, invocationContext, iteratorOperation, keyPartitioner, keysToFilter, localAddress, parallel, parallelDistribution, partition, registry, rehashAware, segmentCompletionListener, segmentsToFilter, stateTransferLock, timeout, timeoutUnit, toKeyFunction
-
Constructor Summary
ModifierConstructorDescriptionprotected
This constructor is to be used only when a user calls a map or flat map method changing to an IntStream from a CacheStream, Stream, DoubleStream, IntStream etc. -
Method Summary
Modifier and TypeMethodDescriptionboolean
allMatch
(LongPredicate predicate) boolean
anyMatch
(LongPredicate predicate) average()
boxed()
protected <R> DistributedCacheStream
<Original, R> <R> R
collect
(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R, R> combiner) long
count()
Disables tracking of rehash events that could occur to the underlying cache.distinct()
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.protected DistributedDoubleCacheStream
<Original> filter
(LongPredicate predicate) filter
(SerializableLongPredicate predicate) Same asLongCacheStream.filter(LongPredicate)
except that the LongPredicate must also implement Serializable.filterKeys
(Set<?> keys) Filters which entries are returned by only returning ones that map to the given key.filterKeySegments
(Set<Integer> segments) Filters which entries are returned by what segment they are present in.filterKeySegments
(IntSet segments) Filters which entries are returned by what segment they are present in.findAny()
flatMap
(LongFunction<? extends LongStream> mapper) flatMap
(SerializableLongFunction<? extends LongStream> mapper) Same asLongCacheStream.flatMap(LongFunction)
except that the LongFunction must also implement Serializable.void
forEach
(LongConsumer action) <K,
V> void forEach
(ObjLongConsumer<Cache<K, V>> action) Same asLongStream.forEach(LongConsumer)
except that it takes anObjLongConsumer
that provides access to the underlyingCache
that is backing this stream.void
forEach
(SerializableLongConsumer action) Same asLongStream.forEach(LongConsumer)
except that the LongConsumer must also implement Serializable.<K,
V> void forEach
(SerializableObjLongConsumer<Cache<K, V>> action) Same asLongCacheStream.forEach(ObjLongConsumer)
except that theBiConsumer
must also implementSerializable
void
forEachOrdered
(LongConsumer action) protected org.infinispan.util.logging.Log
getLog()
protected DistributedIntCacheStream
<Original> iterator()
limit
(long maxSize) map
(LongUnaryOperator mapper) map
(SerializableLongUnaryOperator mapper) Same asLongCacheStream.map(LongUnaryOperator)
except that the LongUnaryOperator must also implement Serializable.mapToDouble
(LongToDoubleFunction mapper) Same asLongCacheStream.mapToDouble(LongToDoubleFunction)
except that the LongToLongFunction must also implement Serializable.mapToInt
(LongToIntFunction mapper) Same asLongCacheStream.mapToInt(LongToIntFunction)
except that the LongToIntFunction must also implement Serializable.<U> CacheStream
<U> mapToObj
(LongFunction<? extends U> mapper) <U> CacheStream
<U> mapToObj
(SerializableLongFunction<? extends U> mapper) Same asLongCacheStream.mapToObj(LongFunction)
except that the LongFunction must also implement Serializable.max()
min()
boolean
noneMatch
(LongPredicate predicate) This would enable sending requests to all other remote nodes when a terminal operator is performed.peek
(LongConsumer action) peek
(SerializableLongConsumer action) Same asLongCacheStream.flatMap(LongFunction)
except that the LongFunction must also implement Serializable.long
reduce
(long identity, LongBinaryOperator op) Allows registration of a segment completion listener that is notified when a segment has completed processing.This would disable sending requests to all other remote nodes compared to one at a time.skip
(long n) sorted()
long
sum()
Sets a given time to wait for a remote operation to respond by.long[]
toArray()
protected LongCacheStream
unwrap()
Methods inherited from class org.infinispan.stream.impl.AbstractCacheStream
addIntermediateOperation, addIntermediateOperation, addIntermediateOperationMap, close, composeWithExceptions, isParallel, isPrimaryOwner, onClose, parallel, sequential, unordered
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.util.stream.BaseStream
close, isParallel
Methods inherited from interface org.infinispan.LongCacheStream
allMatch, anyMatch, collect, noneMatch, onClose, parallel, reduce, reduce, sequential, unordered
Methods inherited from interface java.util.stream.LongStream
dropWhile, takeWhile
-
Constructor Details
-
DistributedLongCacheStream
This constructor is to be used only when a user calls a map or flat map method changing to an IntStream from a CacheStream, Stream, DoubleStream, IntStream etc.- Parameters:
other
- other instance ofAbstractCacheStream
to copy details from
-
-
Method Details
-
getLog
protected org.infinispan.util.logging.Log getLog()- Specified by:
getLog
in classAbstractCacheStream<Original,
Long, LongStream, LongCacheStream>
-
unwrap
- Specified by:
unwrap
in classAbstractCacheStream<Original,
Long, LongStream, LongCacheStream>
-
filter
Description copied from interface:LongCacheStream
- Specified by:
filter
in interfaceLongCacheStream
- Specified by:
filter
in interfaceLongStream
- Returns:
- the new cache long stream
-
filter
Description copied from interface:LongCacheStream
Same asLongCacheStream.filter(LongPredicate)
except that the LongPredicate must also implement Serializable.This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.
- Specified by:
filter
in interfaceLongCacheStream
- Parameters:
predicate
- a non-interfering, stateless predicate to apply to each element to determine if it should be included- Returns:
- the new cache long stream
-
map
Description copied from interface:LongCacheStream
- Specified by:
map
in interfaceLongCacheStream
- Specified by:
map
in interfaceLongStream
- Returns:
- the new cache long stream
-
map
Description copied from interface:LongCacheStream
Same asLongCacheStream.map(LongUnaryOperator)
except that the LongUnaryOperator must also implement Serializable.This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.
- Specified by:
map
in interfaceLongCacheStream
- Parameters:
mapper
- a non-interfering, stateless function to apply to each element- Returns:
- the new cache long stream
-
mapToObj
Description copied from interface:LongCacheStream
- Specified by:
mapToObj
in interfaceLongCacheStream
- Specified by:
mapToObj
in interfaceLongStream
- Returns:
- the new cache stream
-
mapToObj
Description copied from interface:LongCacheStream
Same asLongCacheStream.mapToObj(LongFunction)
except that the LongFunction must also implement Serializable.This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.
- Specified by:
mapToObj
in interfaceLongCacheStream
- 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
Description copied from interface:LongCacheStream
- Specified by:
mapToInt
in interfaceLongCacheStream
- Specified by:
mapToInt
in interfaceLongStream
- Returns:
- the new cache int stream
-
mapToInt
Description copied from interface:LongCacheStream
Same asLongCacheStream.mapToInt(LongToIntFunction)
except that the LongToIntFunction must also implement Serializable.This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.
- Specified by:
mapToInt
in interfaceLongCacheStream
- Parameters:
mapper
- a non-interfering, stateless function to apply to each element- Returns:
- the new cache int stream
-
mapToDouble
Description copied from interface:LongCacheStream
- Specified by:
mapToDouble
in interfaceLongCacheStream
- Specified by:
mapToDouble
in interfaceLongStream
- Returns:
- the new cache double stream
-
mapToDouble
Description copied from interface:LongCacheStream
Same asLongCacheStream.mapToDouble(LongToDoubleFunction)
except that the LongToLongFunction must also implement Serializable.This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.
- Specified by:
mapToDouble
in interfaceLongCacheStream
- Parameters:
mapper
- a non-interfering, stateless function to apply to each element- Returns:
- the new cache double stream
-
flatMap
Description copied from interface:LongCacheStream
- Specified by:
flatMap
in interfaceLongCacheStream
- Specified by:
flatMap
in interfaceLongStream
- Returns:
- the new cache long stream
-
flatMap
Description copied from interface:LongCacheStream
Same asLongCacheStream.flatMap(LongFunction)
except that the LongFunction must also implement Serializable.This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.
- Specified by:
flatMap
in interfaceLongCacheStream
- Parameters:
mapper
- a non-interfering, stateless function to apply to each element which produces aLongStream
of new values- Returns:
- the new cache long stream
-
distinct
Description copied from interface:LongCacheStream
- Specified by:
distinct
in interfaceLongCacheStream
- Specified by:
distinct
in interfaceLongStream
- Returns:
- the new cache long stream
-
sorted
Description copied from interface:LongCacheStream
- Specified by:
sorted
in interfaceLongCacheStream
- Specified by:
sorted
in interfaceLongStream
- Returns:
- the new cache long stream
-
peek
Description copied from interface:LongCacheStream
- Specified by:
peek
in interfaceLongCacheStream
- Specified by:
peek
in interfaceLongStream
- Returns:
- the new cache long stream
-
peek
Description copied from interface:LongCacheStream
Same asLongCacheStream.flatMap(LongFunction)
except that the LongFunction must also implement Serializable.This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.
- Specified by:
peek
in interfaceLongCacheStream
- Parameters:
action
- a non-interfering action to perform on the elements as they are consumed from the stream- Returns:
- the new cache long stream
-
asDoubleStream
Description copied from interface:LongCacheStream
- Specified by:
asDoubleStream
in interfaceLongCacheStream
- Specified by:
asDoubleStream
in interfaceLongStream
- Returns:
- the cache double stream
-
boxed
Description copied from interface:LongCacheStream
- Specified by:
boxed
in interfaceLongCacheStream
- Specified by:
boxed
in interfaceLongStream
- Returns:
- the new cache stream containing longs
-
limit
Description copied from interface:LongCacheStream
- Specified by:
limit
in interfaceLongCacheStream
- Specified by:
limit
in interfaceLongStream
- Returns:
- the new cache long stream
-
skip
Description copied from interface:LongCacheStream
- Specified by:
skip
in interfaceLongCacheStream
- Specified by:
skip
in interfaceLongStream
- Returns:
- the new cache long stream
-
forEach
- Specified by:
forEach
in interfaceLongStream
-
forEach
Description copied from interface:LongCacheStream
Same asLongStream.forEach(LongConsumer)
except that the LongConsumer must also implement Serializable.This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.
- Specified by:
forEach
in interfaceLongCacheStream
- Parameters:
action
- a non-interfering action to perform on the elements
-
forEach
Description copied from interface:LongCacheStream
Same asLongStream.forEach(LongConsumer)
except that it takes anObjLongConsumer
that provides access to the underlyingCache
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 interfaceLongCacheStream
- 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
Description copied from interface:LongCacheStream
Same asLongCacheStream.forEach(ObjLongConsumer)
except that theBiConsumer
must also implementSerializable
- Specified by:
forEach
in interfaceLongCacheStream
- 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
-
forEachOrdered
- Specified by:
forEachOrdered
in interfaceLongStream
-
toArray
public long[] toArray()- Specified by:
toArray
in interfaceLongStream
-
reduce
- Specified by:
reduce
in interfaceLongStream
-
reduce
- Specified by:
reduce
in interfaceLongStream
-
collect
public <R> R collect(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R, R> combiner) - Specified by:
collect
in interfaceLongStream
-
sum
public long sum()- Specified by:
sum
in interfaceLongStream
-
min
- Specified by:
min
in interfaceLongStream
-
max
- Specified by:
max
in interfaceLongStream
-
average
- Specified by:
average
in interfaceLongStream
-
summaryStatistics
- Specified by:
summaryStatistics
in interfaceLongStream
-
anyMatch
- Specified by:
anyMatch
in interfaceLongStream
-
allMatch
- Specified by:
allMatch
in interfaceLongStream
-
noneMatch
- Specified by:
noneMatch
in interfaceLongStream
-
findFirst
- Specified by:
findFirst
in interfaceLongStream
-
findAny
- Specified by:
findAny
in interfaceLongStream
-
iterator
- Specified by:
iterator
in interfaceBaseStream<Long,
LongStream> - Specified by:
iterator
in interfaceLongStream
-
spliterator
- Specified by:
spliterator
in interfaceBaseStream<Long,
LongStream> - Specified by:
spliterator
in interfaceLongStream
-
count
public long count()- Specified by:
count
in interfaceLongStream
-
sequentialDistribution
Description copied from interface:LongCacheStream
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:
sequentialDistribution
in interfaceBaseCacheStream<Long,
LongStream> - Specified by:
sequentialDistribution
in interfaceLongCacheStream
- Returns:
- a stream with parallel distribution disabled.
-
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()
andCacheStream.spliterator()
- Specified by:
parallelDistribution
in interfaceBaseCacheStream<Long,
LongStream> - Specified by:
parallelDistribution
in interfaceLongCacheStream
- Returns:
- a stream with parallel distribution enabled.
-
filterKeySegments
Description copied from interface:LongCacheStream
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:
filterKeySegments
in interfaceBaseCacheStream<Long,
LongStream> - Specified by:
filterKeySegments
in interfaceLongCacheStream
- 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
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 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:
filterKeySegments
in interfaceBaseCacheStream<Long,
LongStream> - 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
Description copied from interface:LongCacheStream
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:
filterKeys
in interfaceBaseCacheStream<Long,
LongStream> - Specified by:
filterKeys
in interfaceLongCacheStream
- Parameters:
keys
- The keys that this stream will only operate on.- Returns:
- a stream with the keys filtered.
-
distributedBatchSize
Description copied from interface:LongCacheStream
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:
distributedBatchSize
in interfaceBaseCacheStream<Long,
LongStream> - Specified by:
distributedBatchSize
in interfaceLongCacheStream
- 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 LongCacheStream segmentCompletionListener(BaseCacheStream.SegmentCompletionListener listener) Description copied from interface:LongCacheStream
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:
segmentCompletionListener
in interfaceBaseCacheStream<Long,
LongStream> - Specified by:
segmentCompletionListener
in interfaceLongCacheStream
- Parameters:
listener
- The listener that will be called back as segments are completed.- Returns:
- a stream with the listener registered.
-
disableRehashAware
Description copied from interface:LongCacheStream
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 interfaceBaseCacheStream<Long,
LongStream> - Specified by:
disableRehashAware
in interfaceLongCacheStream
- Returns:
- a stream with rehash awareness disabled.
-
timeout
Description copied from interface:LongCacheStream
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 theIterator
orSpliterator
.Note that if a rehash occurs this timeout value is reset for the subsequent retry if rehash aware is enabled.
- Specified by:
timeout
in interfaceBaseCacheStream<Long,
LongStream> - Specified by:
timeout
in interfaceLongCacheStream
- Parameters:
timeout
- the maximum time to waitunit
- the time unit of the timeout argument- Returns:
- a stream with the timeout set
-
cacheStream
-
doubleCacheStream
-
intCacheStream
-