E_IN
- type of elements in the upstream sourcepublic abstract static class DoublePipeline.StatefulOp<E_IN> extends DoublePipeline<E_IN>
DoublePipeline.Head<E_IN>, DoublePipeline.StatefulOp<E_IN>, DoublePipeline.StatelessOp<E_IN>
DoubleStream.Builder
sourceOrOpFlags
Constructor and Description |
---|
StatefulOp(AbstractPipeline<?,E_IN,?> upstream,
StreamShape inputShape,
int opFlags)
Construct a new DoubleStream by appending a stateful intermediate
operation to an existing stream.
|
Modifier and Type | Method and Description |
---|---|
abstract <P_IN> Node<Double> |
opEvaluateParallel(PipelineHelper<Double> helper,
Spliterator<P_IN> spliterator,
IntFunction<Double[]> generator)
Performs a parallel evaluation of the operation using the specified
PipelineHelper which describes the upstream intermediate
operations. |
boolean |
opIsStateful()
Returns whether this operation is stateful or not.
|
allMatch, anyMatch, average, boxed, collect, count, distinct, evaluateToNode, filter, findAny, findFirst, flatMap, forEach, forEachOrdered, forEachWithCancel, getOutputShape, iterator, lazySpliterator, limit, makeNodeBuilder, map, mapToInt, mapToLong, mapToObj, max, min, noneMatch, peek, reduce, reduce, skip, sorted, spliterator, sum, summaryStatistics, toArray, unordered, wrap
close, evaluate, evaluateToArrayNode, getStreamAndOpFlags, getStreamFlags, isParallel, onClose, opEvaluateParallelLazy, opWrapSink, parallel, sequential, wrapSink
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, concat, empty, generate, iterate, of, of, parallel, sequential
close, isParallel, onClose
public StatefulOp(AbstractPipeline<?,E_IN,?> upstream, StreamShape inputShape, int opFlags)
upstream
- the upstream pipeline stageinputShape
- the stream shape for the upstream pipeline stageopFlags
- operation flags for the new stagepublic final boolean opIsStateful()
AbstractPipeline
AbstractPipeline.opEvaluateParallel(PipelineHelper, java.util.Spliterator, java.util.function.IntFunction)
must be overridden.opIsStateful
in class AbstractPipeline<E_IN,Double,DoubleStream>
true
if this operation is statefulpublic abstract <P_IN> Node<Double> opEvaluateParallel(PipelineHelper<Double> helper, Spliterator<P_IN> spliterator, IntFunction<Double[]> generator)
AbstractPipeline
PipelineHelper
which describes the upstream intermediate
operations. Only called on stateful operations. If AbstractPipeline.opIsStateful()
returns true then implementations must override the
default implementation.opEvaluateParallel
in class AbstractPipeline<E_IN,Double,DoubleStream>
helper
- the pipeline helper describing the pipeline stagesspliterator
- the source Spliterator
generator
- the array generatorNode
describing the result of the evaluation