org.infinispan.stream.impl.termop.primitive

Class ForEachFlatMapLongOperation<K>

java.lang.Object

org.infinispan.stream.impl.termop.BaseTerminalOperation

org.infinispan.stream.impl.termop.AbstractForEachOperation<K,Long,LongStream>

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

Type Parameters:

K - key type of the supplied stream

All Implemented Interfaces:

KeyTrackingTerminalOperation<K,Long,K>, SegmentAwareOperation

public class ForEachFlatMapLongOperation<K>
extends AbstractForEachOperation<K,Long,LongStream>

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

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

Method Summary

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

ForEachFlatMapLongOperation

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

Method Detail

handleList

protected void handleList(List<Long> list)

Specified by:

handleList in class AbstractForEachOperation<K,Long,LongStream>

handleStreamForEach

protected void handleStreamForEach(LongStream stream,
                                   List<Long> list)

Specified by:

handleStreamForEach in class AbstractForEachOperation<K,Long,LongStream>

getConsumer

public LongConsumer 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,Long,K>

Overrides:

handleInjection in class BaseTerminalOperation

Parameters:

registry - component registry to use