6225aa6fbdc742f23770ba1f373c7a0f9e7e32d7
Files Diff
- Added: 4
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Pull Up Method | 4 | ||
Pull Up Method public extractTimestamp(element T, elementPrevTimestamp long) : long from class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor to public extractTimestamp(element T, elementPrevTimestamp long) : long from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor | From | To | |
Pull Up Method public withViolationHandler(handler MonotonyViolationHandler) : AscendingTimestampExtractor<T> from class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor to public withViolationHandler(handler MonotonyViolationHandler) : AscendingTimestampExtractor<T> from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor | From | To | |
Pull Up Method public getCurrentWatermark() : Watermark from class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor to public getCurrentWatermark() : Watermark from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor | From | To | |
Pull Up Method public abstract extractAscendingTimestamp(element T) : long from class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor to public abstract extractAscendingTimestamp(element T) : long from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor | From | To | |
Pull Up Attribute | 3 | ||
Pull Up Attribute private violationHandler : MonotonyViolationHandler from class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor to private violationHandler : MonotonyViolationHandler from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor | From | To | |
Pull Up Attribute private serialVersionUID : long from class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor to private serialVersionUID : long from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor | From | To | |
Pull Up Attribute private currentTimestamp : long from class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor to private currentTimestamp : long from class org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor | From | To | |
Move Class | 4 | ||
Move Class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor.FailingHandler moved to org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.FailingHandler | From | To | |
Move Class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor.LoggingHandler moved to org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.LoggingHandler | From | To | |
Move Class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor.IgnoringHandler moved to org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.IgnoringHandler | From | To | |
Move Class org.apache.flink.streaming.api.functions.AscendingTimestampExtractor.MonotonyViolationHandler moved to org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.MonotonyViolationHandler | From | To | |
Extract Superclass | 1 | ||
Extract Superclass org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor from classes [org.apache.flink.streaming.api.functions.AscendingTimestampExtractor] | From | To |