Interface AscendingTimestampExtractor.MonotonyViolationHandler
-
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
AscendingTimestampExtractor.FailingHandler,AscendingTimestampExtractor.IgnoringHandler,AscendingTimestampExtractor.LoggingHandler
- Enclosing class:
- AscendingTimestampExtractor<T>
public static interface AscendingTimestampExtractor.MonotonyViolationHandler extends Serializable
Interface for handlers that handle violations of the monotonous ascending timestamps property.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidhandleViolation(long elementTimestamp, long lastTimestamp)Called when the property of monotonously ascending timestamps is violated, i.e., whenelementTimestamp < lastTimestamp.
-
-
-
Method Detail
-
handleViolation
void handleViolation(long elementTimestamp, long lastTimestamp)Called when the property of monotonously ascending timestamps is violated, i.e., whenelementTimestamp < lastTimestamp.- Parameters:
elementTimestamp- The timestamp of the current element.lastTimestamp- The last timestamp.
-
-