4779c7eca0f7e91dd5ee38122baa3fe99c8b7bea
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 12
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 3 | ||
| Change Parameter Type task : StreamTask<?,?> to task : AsyncExceptionHandler in method package TriggerTask(task AsyncExceptionHandler, lock Object, target Triggerable, timestamp long) in class org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider.TriggerTask | From | To | |
| Change Parameter Type target : Runnable to target : Triggerable in method public registerTimer(timestamp long, target Triggerable) : ScheduledFuture<?> in class org.apache.flink.streaming.runtime.tasks.TestTimeServiceProvider | From | To | |
| Change Parameter Type target : Runnable to target : Triggerable in method public abstract registerTimer(timestamp long, target Triggerable) : ScheduledFuture<?> in class org.apache.flink.streaming.runtime.tasks.TimeServiceProvider | From | To | |
| Move Method | 1 | ||
| Move Method public testCustomTimeServiceProvider() : void from class org.apache.flink.streaming.runtime.operators.StreamTaskTimerTest to public testCustomTimeServiceProvider() : void from class org.apache.flink.streaming.runtime.operators.TimeProviderTest | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private checkpointLock : Object from class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext to private checkpointLock : Object from class org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.streaming.runtime.tasks.StreamTask.TriggerTask moved to org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider.TriggerTask | From | To | |
| Change Variable Type | 5 | ||
| Change Variable Type it : Iterator<Map.Entry<Long,List<Runnable>>> to it : Iterator<Map.Entry<Long,List<Triggerable>>> in method public setCurrentTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.TestTimeServiceProvider | From | To | |
| Change Variable Type tasks : List<Runnable> to tasks : List<Triggerable> in method public registerTimer(timestamp long, target Triggerable) : ScheduledFuture<?> in class org.apache.flink.streaming.runtime.tasks.TestTimeServiceProvider | From | To | |
| Change Variable Type toRun : List<Runnable> to toRun : List<Map.Entry<Long,List<Triggerable>>> in method public setCurrentTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.TestTimeServiceProvider | From | To | |
| Change Variable Type tasks : List<Runnable> to tasks : List<Triggerable> in method public getNoOfRegisteredTimers() : int in class org.apache.flink.streaming.runtime.tasks.TestTimeServiceProvider | From | To | |
| Change Variable Type t : Map.Entry<Long,List<Runnable>> to t : Map.Entry<Long,List<Triggerable>> in method public setCurrentTime(timestamp long) : void in class org.apache.flink.streaming.runtime.tasks.TestTimeServiceProvider | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type task : StreamTask<?,?> to task : AsyncExceptionHandler in class org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider.TriggerTask | From | To | |
| Change Attribute Type registeredTasks : Map<Long,List<Runnable>> to registeredTasks : Map<Long,List<Triggerable>> in class org.apache.flink.streaming.runtime.tasks.TestTimeServiceProvider | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public registerAsyncException(message String, exception AsynchronousException) : void extracted from public run() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable & moved to class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To |