Class ForEachDoubleOperation<Original,K>
- java.lang.Object
-
- org.infinispan.stream.impl.termop.BaseTerminalOperation<Original>
-
- org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation<Original,K>
-
- org.infinispan.stream.impl.termop.primitive.ForEachDoubleOperation<Original,K>
-
- Type Parameters:
Original
- original stream typeK
- key type of the supplied stream
- All Implemented Interfaces:
KeyTrackingTerminalOperation<Original,K,Double>
,SegmentAwareOperation
public class ForEachDoubleOperation<Original,K> extends AbstractForEachDoubleOperation<Original,K>
Terminal rehash aware operation that handles for each where no flat map operations are defined on aDoubleStream
. Note this means it is an implied map intermediate operation.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.infinispan.stream.impl.KeyTrackingTerminalOperation
KeyTrackingTerminalOperation.IntermediateCollector<C>
-
-
Field Summary
-
Fields inherited from class org.infinispan.stream.impl.termop.BaseTerminalOperation
intermediateOperations, supplier
-
-
Constructor Summary
Constructors Constructor Description ForEachDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, DoubleConsumer consumer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DoubleConsumer
getConsumer()
protected void
handleArray(double[] array, int size)
void
handleInjection(ComponentRegistry registry)
Handles injection of components for various intermediate and this operation.-
Methods inherited from class org.infinispan.stream.impl.termop.primitive.AbstractForEachDoubleOperation
getBatchSize, getToKeyFunction, lostSegment, performForEachOperation, performOperation
-
Methods inherited from class org.infinispan.stream.impl.termop.BaseTerminalOperation
getIntermediateOperations, setSupplier
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.infinispan.stream.impl.KeyTrackingTerminalOperation
setSupplier
-
-
-
-
Constructor Detail
-
ForEachDoubleOperation
public ForEachDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, DoubleConsumer consumer)
-
-
Method Detail
-
handleArray
protected void handleArray(double[] array, int size)
- Specified by:
handleArray
in classAbstractForEachDoubleOperation<Original,K>
-
getConsumer
public DoubleConsumer getConsumer()
-
handleInjection
public void handleInjection(ComponentRegistry registry)
Description copied from interface:KeyTrackingTerminalOperation
Handles injection of components for various intermediate and this operation.- Specified by:
handleInjection
in interfaceKeyTrackingTerminalOperation<Original,K,Double>
- Overrides:
handleInjection
in classBaseTerminalOperation<Original>
- Parameters:
registry
- component registry to use
-
-