org.infinispan.stream.impl

Class DistributedIntCacheStream

java.lang.Object

org.infinispan.stream.impl.AbstractCacheStream<Integer,IntStream,IntConsumer>

org.infinispan.stream.impl.DistributedIntCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Integer,IntStream>, IntStream

Direct Known Subclasses:

TxDistributedIntCacheStream

public class DistributedIntCacheStream
extends AbstractCacheStream<Integer,IntStream,IntConsumer>
implements IntStream

Implementation of IntStream 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.IntStream

IntStream.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	DistributedIntCacheStream(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, LongStream etc.

Method Summary

Modifier and Type	Method and Description
boolean	allMatch(IntPredicate predicate)
boolean	anyMatch(IntPredicate predicate)
DoubleStream	asDoubleStream()
LongStream	asLongStream()
OptionalDouble	average()
Stream<Integer>	boxed()
protected <R> DistributedCacheStream<R>	cacheStream()
<R> R	collect(Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R,R> combiner)
long	count()
IntStream	distinct()
protected DistributedDoubleCacheStream	doubleCacheStream()
IntStream	filter(IntPredicate predicate)
OptionalInt	findAny()
OptionalInt	findFirst()
IntStream	flatMap(IntFunction<? extends IntStream> mapper)
void	forEach(IntConsumer action)
void	forEachOrdered(IntConsumer action)
PrimitiveIterator.OfInt	iterator()
IntStream	limit(long maxSize)
protected DistributedLongCacheStream	longCacheStream()
IntStream	map(IntUnaryOperator mapper)
DoubleStream	mapToDouble(IntToDoubleFunction mapper)
LongStream	mapToLong(IntToLongFunction mapper)
<U> Stream<U>	mapToObj(IntFunction<? extends U> mapper)
OptionalInt	max()
OptionalInt	min()
boolean	noneMatch(IntPredicate predicate)
IntStream	peek(IntConsumer action)
OptionalInt	reduce(IntBinaryOperator op)
int	reduce(int identity, IntBinaryOperator op)
IntStream	skip(long n)
IntStream	sorted()
Spliterator.OfInt	spliterator()
int	sum()
IntSummaryStatistics	summaryStatistics()
int[]	toArray()
protected DistributedIntCacheStream	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.IntStream

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

DistributedIntCacheStream

protected DistributedIntCacheStream(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, LongStream etc.

Parameters:

other - other instance of AbstractCacheStream to copy details from

Method Detail

unwrap

protected DistributedIntCacheStream unwrap()

Specified by:

unwrap in class AbstractCacheStream<Integer,IntStream,IntConsumer>

filter

public IntStream filter(IntPredicate predicate)

Specified by:

filter in interface IntStream

map

public IntStream map(IntUnaryOperator mapper)

Specified by:

map in interface IntStream

mapToObj

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

Specified by:

mapToObj in interface IntStream

mapToLong

public LongStream mapToLong(IntToLongFunction mapper)

Specified by:

mapToLong in interface IntStream

mapToDouble

public DoubleStream mapToDouble(IntToDoubleFunction mapper)

Specified by:

mapToDouble in interface IntStream

flatMap

public IntStream flatMap(IntFunction<? extends IntStream> mapper)

Specified by:

flatMap in interface IntStream

distinct

public IntStream distinct()

Specified by:

distinct in interface IntStream

sorted

public IntStream sorted()

Specified by:

sorted in interface IntStream

peek

public IntStream peek(IntConsumer action)

Specified by:

peek in interface IntStream

limit

public IntStream limit(long maxSize)

Specified by:

limit in interface IntStream

skip

public IntStream skip(long n)

Specified by:

skip in interface IntStream

asLongStream

public LongStream asLongStream()

Specified by:

asLongStream in interface IntStream

asDoubleStream

public DoubleStream asDoubleStream()

Specified by:

asDoubleStream in interface IntStream

boxed

public Stream<Integer> boxed()

Specified by:

boxed in interface IntStream

forEach

public void forEach(IntConsumer action)

Specified by:

forEach in interface IntStream

forEachOrdered

public void forEachOrdered(IntConsumer action)

Specified by:

forEachOrdered in interface IntStream

toArray

public int[] toArray()

Specified by:

toArray in interface IntStream

reduce

public int reduce(int identity,
                  IntBinaryOperator op)

Specified by:

reduce in interface IntStream

reduce

public OptionalInt reduce(IntBinaryOperator op)

Specified by:

reduce in interface IntStream

collect

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

Specified by:

collect in interface IntStream

sum

public int sum()

Specified by:

sum in interface IntStream

min

public OptionalInt min()

Specified by:

min in interface IntStream

max

public OptionalInt max()

Specified by:

max in interface IntStream

average

public OptionalDouble average()

Specified by:

average in interface IntStream

summaryStatistics

public IntSummaryStatistics summaryStatistics()

Specified by:

summaryStatistics in interface IntStream

anyMatch

public boolean anyMatch(IntPredicate predicate)

Specified by:

anyMatch in interface IntStream

allMatch

public boolean allMatch(IntPredicate predicate)

Specified by:

allMatch in interface IntStream

noneMatch

public boolean noneMatch(IntPredicate predicate)

Specified by:

noneMatch in interface IntStream

findFirst

public OptionalInt findFirst()

Specified by:

findFirst in interface IntStream

findAny

public OptionalInt findAny()

Specified by:

findAny in interface IntStream

iterator

public PrimitiveIterator.OfInt iterator()

Specified by:

iterator in interface BaseStream<Integer,IntStream>

Specified by:

iterator in interface IntStream

spliterator

public Spliterator.OfInt spliterator()

Specified by:

spliterator in interface BaseStream<Integer,IntStream>

Specified by:

spliterator in interface IntStream

count

public long count()

Specified by:

count in interface IntStream

cacheStream

protected <R> DistributedCacheStream<R> cacheStream()

doubleCacheStream

protected DistributedDoubleCacheStream doubleCacheStream()

longCacheStream

protected DistributedLongCacheStream longCacheStream()