94a3f251cd3eed54c7d8220db119eecbfb11c3b9
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 14
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 5 | ||
| Change Parameter Type triggerable : Triggerable to processingTimeCallback : ProcessingTimeCallback in method public ScheduledTimerFuture(processingTimeCallback ProcessingTimeCallback, timestamp long) in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService.ScheduledTimerFuture | From | To | |
| Change Parameter Type target : Triggerable to target : ProcessingTimeCallback in method public abstract registerTimer(timestamp long, target ProcessingTimeCallback) : ScheduledFuture<?> in class org.apache.flink.streaming.runtime.tasks.ProcessingTimeService | From | To | |
| Change Parameter Type target : Triggerable to target : ProcessingTimeCallback in method public registerTimer(timestamp long, target ProcessingTimeCallback) : ScheduledFuture<?> in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService | From | To | |
| Change Parameter Type target : Triggerable to target : ProcessingTimeCallback in method package TriggerTask(exceptionHandler AsyncExceptionHandler, lock Object, target ProcessingTimeCallback, timestamp long) in class org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.TriggerTask | From | To | |
| Change Parameter Type target : Triggerable to target : ProcessingTimeCallback in method public registerTimer(timestamp long, target ProcessingTimeCallback) : ScheduledFuture<?> in class org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.runtime.operators.StreamTaskTimerTest.ValidatingTriggerable renamed to org.apache.flink.streaming.runtime.operators.StreamTaskTimerTest.ValidatingProcessingTimeCallback | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.runtime.operators.Triggerable moved and renamed to org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute triggerable : Triggerable to processingTimeCallback : ProcessingTimeCallback in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService.ScheduledTimerFuture | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type trigger : Triggerable to trigger : ProcessingTimeCallback in method public testTimerSorting() : void in class org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeServiceTest | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type target : Triggerable to target : ProcessingTimeCallback in class org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.TriggerTask | From | To | |
| Change Attribute Type triggerable : Triggerable to processingTimeCallback : ProcessingTimeCallback in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService.ScheduledTimerFuture | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter triggerable : Triggerable to processingTimeCallback : ProcessingTimeCallback in method public ScheduledTimerFuture(processingTimeCallback ProcessingTimeCallback, timestamp long) in class org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService.ScheduledTimerFuture | From | To |