Class AscendingTimestampExtractor.LoggingHandler
- java.lang.Object
-
- org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.LoggingHandler
-
- All Implemented Interfaces:
Serializable,AscendingTimestampExtractor.MonotonyViolationHandler
- Enclosing class:
- AscendingTimestampExtractor<T>
public static final class AscendingTimestampExtractor.LoggingHandler extends Object implements AscendingTimestampExtractor.MonotonyViolationHandler
Handler that only logs violations of timestamp monotony, on WARN log level.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description LoggingHandler()
-
Method Summary
All Methods Instance Methods Concrete 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
public void handleViolation(long elementTimestamp, long lastTimestamp)Description copied from interface:AscendingTimestampExtractor.MonotonyViolationHandlerCalled when the property of monotonously ascending timestamps is violated, i.e., whenelementTimestamp < lastTimestamp.- Specified by:
handleViolationin interfaceAscendingTimestampExtractor.MonotonyViolationHandler- Parameters:
elementTimestamp- The timestamp of the current element.lastTimestamp- The last timestamp.
-
-