be3f80929d220d797da93bb3a959613dcff3a889
Files Diff
- Added: 7
- Removed: 2
- Renamed: 0
- Modified: 13
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type taskExecutorConfig : TaskExecutorConfiguration to taskManagerConfiguration : TaskManagerConfiguration in method public TaskExecutor(taskManagerConfiguration TaskManagerConfiguration, taskManagerLocation TaskManagerLocation, rpcService RpcService, memoryManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, haServices HighAvailabilityServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Move Method | 2 | ||
| Move Method public getNumberOfSlots() : int from class org.apache.flink.runtime.taskexecutor.TaskExecutorConfiguration to public getNumberOfSlots() : int from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration | From | To | |
| Move Method public getNetworkConfig() : NetworkEnvironmentConfiguration from class org.apache.flink.runtime.taskexecutor.TaskExecutorConfiguration to public getNetworkConfig() : NetworkEnvironmentConfiguration from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration | From | To | |
| Rename Variable | 2 | ||
| Rename Variable taskExecutorConfiguration : TaskExecutorConfiguration to taskManagerServicesConfiguration : TaskManagerConfiguration in method public testTriggerRegistrationOnLeaderChange() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest | From | To | |
| Rename Variable taskExecutorConfiguration : TaskExecutorConfiguration to taskManagerServicesConfiguration : TaskManagerConfiguration in method public testImmediatelyRegistersIfLeaderIsKnown() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest | From | To | |
| Change Return Type | 5 | ||
| Change Return Type FiniteDuration to Time in method public getRefusedRegistrationPause() : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Change Return Type FiniteDuration to Time in method public getMaxRegistrationPause() : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Change Return Type FiniteDuration to Time in method public getInitialRegistrationPause() : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Change Return Type FiniteDuration to Time in method public getMaxRegistrationDuration() : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Change Return Type FiniteDuration to Time in method public getTimeout() : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Move Attribute | 2 | ||
| Move Attribute private numberOfSlots : int from class org.apache.flink.runtime.taskexecutor.TaskExecutorConfiguration to private numberOfSlots : int from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration | From | To | |
| Move Attribute private networkConfig : NetworkEnvironmentConfiguration from class org.apache.flink.runtime.taskexecutor.TaskExecutorConfiguration to private networkConfig : NetworkEnvironmentConfiguration from class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration from class org.apache.flink.runtime.taskexecutor.TaskExecutorConfiguration | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.runtime.taskexecutor.TaskExecutorConfiguration renamed to org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.runtime.taskmanager.TaskManagerRunner.TaskManagerComponents moved and renamed to org.apache.flink.runtime.taskexecutor.TaskManagerServices | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute taskExecutorConfig : TaskExecutorConfiguration to taskManagerConfiguration : TaskManagerConfiguration in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type taskExecutorConfiguration : TaskExecutorConfiguration to taskManagerServicesConfiguration : TaskManagerConfiguration in method public testImmediatelyRegistersIfLeaderIsKnown() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest | From | To | |
| Change Variable Type taskExecutorConfiguration : TaskExecutorConfiguration to taskManagerServicesConfiguration : TaskManagerConfiguration in method public testTriggerRegistrationOnLeaderChange() : void in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest | From | To | |
| Change Attribute Type | 6 | ||
| Change Attribute Type taskExecutorConfig : TaskExecutorConfiguration to taskManagerConfiguration : TaskManagerConfiguration in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To | |
| Change Attribute Type maxRegistrationDuration : FiniteDuration to maxRegistrationDuration : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Change Attribute Type timeout : FiniteDuration to timeout : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Change Attribute Type initialRegistrationPause : FiniteDuration to initialRegistrationPause : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Change Attribute Type refusedRegistrationPause : FiniteDuration to refusedRegistrationPause : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Change Attribute Type maxRegistrationPause : FiniteDuration to maxRegistrationPause : Time in class org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter taskExecutorConfig : TaskExecutorConfiguration to taskManagerConfiguration : TaskManagerConfiguration in method public TaskExecutor(taskManagerConfiguration TaskManagerConfiguration, taskManagerLocation TaskManagerLocation, rpcService RpcService, memoryManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, haServices HighAvailabilityServices, metricRegistry MetricRegistry, fatalErrorHandler FatalErrorHandler) in class org.apache.flink.runtime.taskexecutor.TaskExecutor | From | To |