Class ForEachFlatMapObjIntOperation<Original,K>
- java.lang.Object
-
- org.infinispan.stream.impl.termop.BaseTerminalOperation<Original>
-
- org.infinispan.stream.impl.termop.AbstractForEachOperation<Original,K,Integer,IntStream>
-
- org.infinispan.stream.impl.termop.primitive.ForEachFlatMapObjIntOperation<Original,K>
-
- Type Parameters:
Original
- original stream typeK
- key type of the supplied stream
- All Implemented Interfaces:
KeyTrackingTerminalOperation<Original,K,Integer>
,SegmentAwareOperation
public class ForEachFlatMapObjIntOperation<Original,K> extends AbstractForEachOperation<Original,K,Integer,IntStream>
Terminal rehash aware operation that handles for each where flat map operation is performed on aIntStream
.
-
-
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 ForEachFlatMapObjIntOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<Stream<Original>> supplier, Function<? super Original,? extends K> toKeyFunction, int batchSize, ObjIntConsumer<Cache<K,?>> consumer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ObjIntConsumer<Cache<K,?>>
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, 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
-
-
-
-
Method Detail
-
handleList
protected void handleList(List<Integer> list)
- Specified by:
handleList
in classAbstractForEachOperation<Original,K,Integer,IntStream>
-
handleStreamForEach
protected void handleStreamForEach(IntStream stream, List<Integer> list)
- Specified by:
handleStreamForEach
in classAbstractForEachOperation<Original,K,Integer,IntStream>
-
getConsumer
public ObjIntConsumer<Cache<K,?>> 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,Integer>
- Overrides:
handleInjection
in classBaseTerminalOperation<Original>
- Parameters:
registry
- component registry to use
-
-