org.infinispan.stream.impl.termop.primitive

Class ForEachFlatMapDoubleOperation<K>

java.lang.Object

org.infinispan.stream.impl.termop.BaseTerminalOperation

org.infinispan.stream.impl.termop.AbstractForEachOperation<K,Double,DoubleStream>

org.infinispan.stream.impl.termop.primitive.ForEachFlatMapDoubleOperation<K>

Type Parameters:

K - key type of the supplied stream

All Implemented Interfaces:

KeyTrackingTerminalOperation<K,Double,K>, SegmentAwareOperation

public class ForEachFlatMapDoubleOperation<K>
extends AbstractForEachOperation<K,Double,DoubleStream>

Terminal rehash aware operation that handles for each where flat map operation is performed on a DoubleStream.

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 and Description
ForEachFlatMapDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<CacheEntry>> supplier, int batchSize, DoubleConsumer consumer)

Method Summary

Modifier and Type	Method and Description
DoubleConsumer	getConsumer()
void	handleInjection(ComponentRegistry registry) Handles injection of components for various intermediate and this operation.
protected void	handleList(List<Double> list)
protected void	handleStreamForEach(DoubleStream stream, List<Double> list)

Methods inherited from class org.infinispan.stream.impl.termop.AbstractForEachOperation

getBatchSize, lostSegment, performOperation, performOperationRehashAware

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

ForEachFlatMapDoubleOperation

public ForEachFlatMapDoubleOperation(Iterable<IntermediateOperation> intermediateOperations,
                                     Supplier<Stream<CacheEntry>> supplier,
                                     int batchSize,
                                     DoubleConsumer consumer)

Method Detail

handleList

protected void handleList(List<Double> list)

Specified by:

handleList in class AbstractForEachOperation<K,Double,DoubleStream>

handleStreamForEach

protected void handleStreamForEach(DoubleStream stream,
                                   List<Double> list)

Specified by:

handleStreamForEach in class AbstractForEachOperation<K,Double,DoubleStream>

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 interface KeyTrackingTerminalOperation<K,Double,K>

Overrides:

handleInjection in class BaseTerminalOperation

Parameters:

registry - component registry to use