E
- type of the output of the functionR
- type of the stream entriesS
- type of the stream itselfpublic class SingleRunOperation<E,R,S extends BaseStream<R,S>> extends BaseTerminalOperation implements TerminalOperation<E>
intermediateOperations, supplier
Constructor and Description |
---|
SingleRunOperation(Iterable<IntermediateOperation> intermediateOperations,
Supplier<? extends BaseStream<?,?>> supplier,
Function<S,? extends E> function) |
Modifier and Type | Method and Description |
---|---|
Function<S,? extends E> |
getFunction() |
boolean |
lostSegment(boolean stopIfLost)
This method will be invoked when the operation is known to be performing on a given set of segments
and this node no longer owns 1 or many of them.
|
E |
performOperation()
Actually runs the terminal operation returning the result from the operation
|
getIntermediateOperations, handleInjection, setSupplier
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handleInjection, setSupplier
public SingleRunOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<? extends BaseStream<?,?>> supplier, Function<S,? extends E> function)
public boolean lostSegment(boolean stopIfLost)
SegmentAwareOperation
lostSegment
in interface SegmentAwareOperation
stopIfLost
- argument to tell the operation that if this segment affects that it should not
perform any more operations if possible as all segments have been lost.public E performOperation()
TerminalOperation
performOperation
in interface TerminalOperation<E>
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.