K
- key type of the supplied streampublic class ForEachFlatMapDoubleOperation<K> extends AbstractForEachOperation<K,Double,DoubleStream>
DoubleStream
.KeyTrackingTerminalOperation.IntermediateCollector<C>
intermediateOperations, supplier
Constructor and Description |
---|
ForEachFlatMapDoubleOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<Stream<CacheEntry>> supplier,
int batchSize,
DoubleConsumer consumer) |
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) |
getBatchSize, lostSegment, performOperation, performOperationRehashAware
getIntermediateOperations, setSupplier
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setSupplier
public ForEachFlatMapDoubleOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<CacheEntry>> supplier, int batchSize, DoubleConsumer consumer)
protected void handleList(List<Double> list)
handleList
in class AbstractForEachOperation<K,Double,DoubleStream>
protected void handleStreamForEach(DoubleStream stream, List<Double> list)
handleStreamForEach
in class AbstractForEachOperation<K,Double,DoubleStream>
public DoubleConsumer getConsumer()
public void handleInjection(ComponentRegistry registry)
KeyTrackingTerminalOperation
handleInjection
in interface KeyTrackingTerminalOperation<K,Double,K>
handleInjection
in class BaseTerminalOperation
registry
- component registry to useCopyright © 2020 JBoss, a division of Red Hat. All rights reserved.