public class DistributedIntCacheStream extends AbstractCacheStream<Integer,IntStream,IntConsumer> implements IntStream
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.IntStream.Builder
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
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.
|
addIntermediateOperation, addIntermediateOperationMap, addIntermediateOperationMap, close, isParallel, markDistinct, markSkip, markSorted, onClose, parallel, sequential, supplierForSegments, supplierForSegments, unordered
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, concat, empty, generate, iterate, of, of, parallel, range, rangeClosed, sequential
close, isParallel, onClose, unordered
protected DistributedIntCacheStream(AbstractCacheStream other)
other
- other instance of AbstractCacheStream
to copy details fromprotected DistributedIntCacheStream unwrap()
unwrap
in class AbstractCacheStream<Integer,IntStream,IntConsumer>
public IntStream filter(IntPredicate predicate)
public IntStream map(IntUnaryOperator mapper)
public <U> Stream<U> mapToObj(IntFunction<? extends U> mapper)
public LongStream mapToLong(IntToLongFunction mapper)
public DoubleStream mapToDouble(IntToDoubleFunction mapper)
mapToDouble
in interface IntStream
public IntStream flatMap(IntFunction<? extends IntStream> mapper)
public IntStream peek(IntConsumer action)
public LongStream asLongStream()
asLongStream
in interface IntStream
public DoubleStream asDoubleStream()
asDoubleStream
in interface IntStream
public void forEach(IntConsumer action)
public void forEachOrdered(IntConsumer action)
forEachOrdered
in interface IntStream
public int reduce(int identity, IntBinaryOperator op)
public OptionalInt reduce(IntBinaryOperator op)
public <R> R collect(Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R,R> combiner)
public OptionalInt min()
public OptionalInt max()
public OptionalDouble average()
public IntSummaryStatistics summaryStatistics()
summaryStatistics
in interface IntStream
public boolean anyMatch(IntPredicate predicate)
public boolean allMatch(IntPredicate predicate)
public boolean noneMatch(IntPredicate predicate)
public OptionalInt findFirst()
public OptionalInt findAny()
public PrimitiveIterator.OfInt iterator()
public Spliterator.OfInt spliterator()
spliterator
in interface BaseStream<Integer,IntStream>
spliterator
in interface IntStream
protected <R> DistributedCacheStream<R> cacheStream()
protected DistributedDoubleCacheStream doubleCacheStream()
protected DistributedLongCacheStream longCacheStream()
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.