ab2125b82ed10389dafecf1712efc1f8fb977c11
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getRegisteredTimerTimestamps() : Set<Long> renamed to public getActiveTimerTimestamps() : Set<Long> in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type lockingObject : Object to processingTimeService : ProcessingTimeService in method public LatencyMarksEmitter(processingTimeService ProcessingTimeService, output Output<StreamRecord<OUT>>, latencyTrackingInterval long, vertexID int, subtaskIndex int) in class org.apache.flink.streaming.api.operators.StreamSource.LatencyMarksEmitter | From | To | |
| Rename Variable | 1 | ||
| Rename Variable timer : ScheduledTimerFuture to entry : Tuple2<Long,CallbackTask> in method public getActiveTimerTimestamps() : Set<Long> in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService.ScheduledTimerFuture renamed to org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService.CallbackTask | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type timer : ScheduledTimerFuture to entry : Tuple2<Long,CallbackTask> in method public getActiveTimerTimestamps() : Set<Long> in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter lockingObject : Object to processingTimeService : ProcessingTimeService in method public LatencyMarksEmitter(processingTimeService ProcessingTimeService, output Output<StreamRecord<OUT>>, latencyTrackingInterval long, vertexID int, subtaskIndex int) in class org.apache.flink.streaming.api.operators.StreamSource.LatencyMarksEmitter | From | To |