954ef08f374d7e7c1f2b469201b1ea05c6376b33
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 15
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getNoOfRegisteredTimers() : int renamed to public getNumRegisteredTimers() : int in class org.apache.flink.streaming.runtime.tasks.TestTimeServiceProvider | From | To | |
| Move And Inline Method | 1 | ||
| Move And Inline Method public create(exceptionHandler AsyncExceptionHandler, executor ScheduledExecutorService, checkpointLock Object) : DefaultTimeServiceProvider moved from class org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider to class org.apache.flink.streaming.runtime.tasks.StreamTask & inlined to public invoke() : void | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type checkpointLock : Object to timeServiceProvider : TimeServiceProvider in method public MockRuntimeContext(numberOfParallelSubtasks int, indexOfThisSubtask int, execConfig ExecutionConfig, timeServiceProvider TimeServiceProvider) in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute timerService : TimeServiceProvider to timeServiceProvider : TimeServiceProvider in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type timerService : ScheduledExecutorService to timerService : ScheduledThreadPoolExecutor in class org.apache.flink.streaming.runtime.tasks.DefaultTimeServiceProvider | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter checkpointLock : Object to timeServiceProvider : TimeServiceProvider in method public MockRuntimeContext(numberOfParallelSubtasks int, indexOfThisSubtask int, execConfig ExecutionConfig, timeServiceProvider TimeServiceProvider) in class org.apache.flink.streaming.connectors.kafka.testutils.MockRuntimeContext | From | To |