org.infinispan.stream.impl

Class DistributedLongCacheStream

java.lang.Object

org.infinispan.stream.impl.AbstractCacheStream<Long,LongStream,LongConsumer>

org.infinispan.stream.impl.DistributedLongCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Long,LongStream>, LongStream

Direct Known Subclasses:

TxDistributedLongCacheStream

public class DistributedLongCacheStream
extends AbstractCacheStream<Long,LongStream,LongConsumer>
implements LongStream

Implementation of LongStream that utilizes a lazily evaluated distributed back end execution. Note this class is only able to be created using Stream.mapToInt(ToIntFunction) or similar methods from the CacheStream interface.

Nested Class Summary

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

LongStream.Builder

Field Summary

Fields inherited from class org.infinispan.stream.impl.AbstractCacheStream

closeRunnable, csm, distinct, distributedBatchSize, dm, executor, includeLoader, intermediateOperations, intermediateType, iteratorOperation, keyEquivalence, keysToFilter, localAddress, localIntermediateOperations, log, parallel, parallelDistribution, partition, registry, rehashAware, segmentCompletionListener, segmentsToFilter, sorted, supplier, timeout, timeoutUnit

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DistributedLongCacheStream(AbstractCacheStream other) 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 Type	Method and Description
boolean	allMatch(LongPredicate predicate)
boolean	anyMatch(LongPredicate predicate)
DoubleStream	asDoubleStream()
OptionalDouble	average()
Stream<Long>	boxed()
protected <R> DistributedCacheStream<R>	cacheStream()
<R> R	collect(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R,R> combiner)
long	count()
LongStream	distinct()
protected DistributedDoubleCacheStream	doubleCacheStream()
LongStream	filter(LongPredicate predicate)
OptionalLong	findAny()
OptionalLong	findFirst()
LongStream	flatMap(LongFunction<? extends LongStream> mapper)
void	forEach(LongConsumer action)
void	forEachOrdered(LongConsumer action)
protected DistributedIntCacheStream	intCacheStream()
PrimitiveIterator.OfLong	iterator()
LongStream	limit(long maxSize)
LongStream	map(LongUnaryOperator mapper)
DoubleStream	mapToDouble(LongToDoubleFunction mapper)
IntStream	mapToInt(LongToIntFunction mapper)
<U> Stream<U>	mapToObj(LongFunction<? extends U> mapper)
OptionalLong	max()
OptionalLong	min()
boolean	noneMatch(LongPredicate predicate)
LongStream	peek(LongConsumer action)
OptionalLong	reduce(LongBinaryOperator op)
long	reduce(long identity, LongBinaryOperator op)
LongStream	skip(long n)
LongStream	sorted()
Spliterator.OfLong	spliterator()
long	sum()
LongSummaryStatistics	summaryStatistics()
long[]	toArray()
protected LongStream	unwrap()

Methods inherited from class org.infinispan.stream.impl.AbstractCacheStream

addIntermediateOperation, addIntermediateOperationMap, addIntermediateOperationMap, close, isParallel, markDistinct, markSkip, markSorted, onClose, parallel, sequential, supplierForSegments, supplierForSegments, 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.LongStream

builder, concat, empty, generate, iterate, of, of, parallel, range, rangeClosed, sequential

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, onClose, unordered

Constructor Detail

DistributedLongCacheStream

protected DistributedLongCacheStream(AbstractCacheStream other)

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 of AbstractCacheStream to copy details from

Method Detail

unwrap

protected LongStream unwrap()

Specified by:

unwrap in class AbstractCacheStream<Long,LongStream,LongConsumer>

filter

public LongStream filter(LongPredicate predicate)

Specified by:

filter in interface LongStream

map

public LongStream map(LongUnaryOperator mapper)

Specified by:

map in interface LongStream

mapToObj

public <U> Stream<U> mapToObj(LongFunction<? extends U> mapper)

Specified by:

mapToObj in interface LongStream

mapToInt

public IntStream mapToInt(LongToIntFunction mapper)

Specified by:

mapToInt in interface LongStream

mapToDouble

public DoubleStream mapToDouble(LongToDoubleFunction mapper)

Specified by:

mapToDouble in interface LongStream

flatMap

public LongStream flatMap(LongFunction<? extends LongStream> mapper)

Specified by:

flatMap in interface LongStream

distinct

public LongStream distinct()

Specified by:

distinct in interface LongStream

sorted

public LongStream sorted()

Specified by:

sorted in interface LongStream

peek

public LongStream peek(LongConsumer action)

Specified by:

peek in interface LongStream

asDoubleStream

public DoubleStream asDoubleStream()

Specified by:

asDoubleStream in interface LongStream

boxed

public Stream<Long> boxed()

Specified by:

boxed in interface LongStream

limit

public LongStream limit(long maxSize)

Specified by:

limit in interface LongStream

skip

public LongStream skip(long n)

Specified by:

skip in interface LongStream

forEach

public void forEach(LongConsumer action)

Specified by:

forEach in interface LongStream

forEachOrdered

public void forEachOrdered(LongConsumer action)

Specified by:

forEachOrdered in interface LongStream

toArray

public long[] toArray()

Specified by:

toArray in interface LongStream

reduce

public long reduce(long identity,
                   LongBinaryOperator op)

Specified by:

reduce in interface LongStream

reduce

public OptionalLong reduce(LongBinaryOperator op)

Specified by:

reduce in interface LongStream

collect

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

Specified by:

collect in interface LongStream

sum

public long sum()

Specified by:

sum in interface LongStream

min

public OptionalLong min()

Specified by:

min in interface LongStream

max

public OptionalLong max()

Specified by:

max in interface LongStream

average

public OptionalDouble average()

Specified by:

average in interface LongStream

summaryStatistics

public LongSummaryStatistics summaryStatistics()

Specified by:

summaryStatistics in interface LongStream

anyMatch

public boolean anyMatch(LongPredicate predicate)

Specified by:

anyMatch in interface LongStream

allMatch

public boolean allMatch(LongPredicate predicate)

Specified by:

allMatch in interface LongStream

noneMatch

public boolean noneMatch(LongPredicate predicate)

Specified by:

noneMatch in interface LongStream

findFirst

public OptionalLong findFirst()

Specified by:

findFirst in interface LongStream

findAny

public OptionalLong findAny()

Specified by:

findAny in interface LongStream

iterator

public PrimitiveIterator.OfLong iterator()

Specified by:

iterator in interface BaseStream<Long,LongStream>

Specified by:

iterator in interface LongStream

spliterator

public Spliterator.OfLong spliterator()

Specified by:

spliterator in interface BaseStream<Long,LongStream>

Specified by:

spliterator in interface LongStream

count

public long count()

Specified by:

count in interface LongStream

cacheStream

protected <R> DistributedCacheStream<R> cacheStream()

doubleCacheStream

protected DistributedDoubleCacheStream doubleCacheStream()

intCacheStream

protected DistributedIntCacheStream intCacheStream()