Package org.infinispan.stream.impl
Interface SegmentAwareOperation
-
- All Known Subinterfaces:
KeyTrackingTerminalOperation<Original,K,R>
,TerminalOperation<Original,R>
- All Known Implementing Classes:
AbstractForEachDoubleOperation
,AbstractForEachIntOperation
,AbstractForEachLongOperation
,AbstractForEachOperation
,ForEachBiOperation
,ForEachDoubleOperation
,ForEachFlatMapDoubleOperation
,ForEachFlatMapIntOperation
,ForEachFlatMapLongOperation
,ForEachFlatMapObjDoubleOperation
,ForEachFlatMapObjIntOperation
,ForEachFlatMapObjLongOperation
,ForEachIntOperation
,ForEachLongOperation
,ForEachObjDoubleOperation
,ForEachObjIntOperation
,ForEachObjLongOperation
,ForEachOperation
,SegmentRetryingOperation
,SingleRunOperation
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
-
-