Package org.infinispan.stream.impl
Interface SegmentAwareOperation
-
- All Known Subinterfaces:
TerminalOperation<Original,R>
public interface SegmentAwareOperation
Terminal stream operation that is aware of segments being lost. This interface describes a single callback method to be invoked on the operation when a segment is lost and it is concurrently running some operation.- Since:
- 8.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description boolean
lostSegment(boolean allSegmentsLost)
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.
-
-
-
Method Detail
-
lostSegment
boolean lostSegment(boolean allSegmentsLost)
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. Returns whether the lost segment affected the results or not. If stopIfLost is true then doneWithOperation will not be invoked as it would normally.- Parameters:
allSegmentsLost
- 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.- Returns:
- whether or not this operation was affected by the loss of segments
-
-