org.infinispan.stream.impl.termop.primitive

Class ForEachFlatMapIntOperation<K>

java.lang.Object

org.infinispan.stream.impl.termop.BaseTerminalOperation

org.infinispan.stream.impl.termop.AbstractForEachOperation<K,Integer,IntStream>

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

Type Parameters:

K - key type of the supplied stream

All Implemented Interfaces:

KeyTrackingTerminalOperation<K,Integer,K>, SegmentAwareOperation

public class ForEachFlatMapIntOperation<K>
extends AbstractForEachOperation<K,Integer,IntStream>

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

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
ForEachFlatMapIntOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<CacheEntry>> supplier, int batchSize, IntConsumer consumer)

Method Summary

Modifier and Type	Method and Description
IntConsumer	getConsumer()
void	handleInjection(ComponentRegistry registry) Handles injection of components for various intermediate and this operation.
protected void	handleList(List<Integer> list)
protected void	handleStreamForEach(IntStream stream, List<Integer> 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

ForEachFlatMapIntOperation

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

Method Detail

handleList

protected void handleList(List<Integer> list)

Specified by:

handleList in class AbstractForEachOperation<K,Integer,IntStream>

handleStreamForEach

protected void handleStreamForEach(IntStream stream,
                                   List<Integer> list)

Specified by:

handleStreamForEach in class AbstractForEachOperation<K,Integer,IntStream>

getConsumer

public IntConsumer 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,Integer,K>

Overrides:

handleInjection in class BaseTerminalOperation

Parameters:

registry - component registry to use