17f0e850fd26da0c50195d3d9daa423ead1fbe3e
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type disconnectJobManagerConsumer : Consumer<Tuple2<JobID,Throwable>> to disconnectJobManagerConsumer : BiConsumer<JobID,Throwable> in method public setDisconnectJobManagerConsumer(disconnectJobManagerConsumer BiConsumer<JobID,Throwable>) : TestingTaskExecutorGatewayBuilder in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder | From | To | |
| Move Method | 2 | ||
| Move Method public setHeartbeatJobManagerConsumer(heartbeatJobManagerConsumer Consumer<ResourceID>) : void from class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGateway to public setHeartbeatJobManagerConsumer(heartbeatJobManagerConsumer Consumer<ResourceID>) : TestingTaskExecutorGatewayBuilder from class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder | From | To | |
| Move Method public setDisconnectJobManagerConsumer(disconnectJobManagerConsumer Consumer<Tuple2<JobID,Throwable>>) : void from class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGateway to public setDisconnectJobManagerConsumer(disconnectJobManagerConsumer BiConsumer<JobID,Throwable>) : TestingTaskExecutorGatewayBuilder from class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder | From | To | |
| Change Return Type | 2 | ||
| Change Return Type void to TestingTaskExecutorGatewayBuilder in method public setHeartbeatJobManagerConsumer(heartbeatJobManagerConsumer Consumer<ResourceID>) : TestingTaskExecutorGatewayBuilder in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder | From | To | |
| Change Return Type void to TestingTaskExecutorGatewayBuilder in method public setDisconnectJobManagerConsumer(disconnectJobManagerConsumer BiConsumer<JobID,Throwable>) : TestingTaskExecutorGatewayBuilder in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGatewayBuilder from class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGateway | From | To | |
| Inline Variable | 1 | ||
| Inline Variable currentHeartbeatJobManagerConsumer : Consumer<ResourceID> in method public heartbeatFromJobManager(heartbeatOrigin ResourceID) : void from class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGateway | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type disconnectJobManagerConsumer : Consumer<Tuple2<JobID,Throwable>> to disconnectJobManagerConsumer : BiConsumer<JobID,Throwable> in class org.apache.flink.runtime.taskexecutor.TestingTaskExecutorGateway | From | To | |
| Extract Method | 1 | ||
| Extract Method private createJobMaster(jobMasterConfiguration JobMasterConfiguration, jobGraph JobGraph, highAvailabilityServices HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices, heartbeatServices HeartbeatServices) : JobMaster extracted from private createJobMaster(jobMasterConfiguration JobMasterConfiguration, jobGraph JobGraph, highAvailabilityServices HighAvailabilityServices, jobManagerSharedServices JobManagerSharedServices) : JobMaster in class org.apache.flink.runtime.jobmaster.JobMasterTest | From | To |