a0bb99c70703f6eaf0953b9ea6e70c5dbb9c1c77
Files Diff
- Added: 13
- Removed: 11
- Renamed: 0
- Modified: 48
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Push Down Method | 3 | ||
| Push Down Method public getJobManagerLeaderRetriever(jobID JobID) : LeaderRetrievalService from class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices to public getJobManagerLeaderRetriever(jobID JobID) : LeaderRetrievalService from class org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices | From | To | |
| Push Down Method private getOrCreateJobManagerService(jobID JobID) : EmbeddedLeaderService from class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices to private getOrCreateJobManagerService(jobID JobID) : EmbeddedLeaderService from class org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices | From | To | |
| Push Down Method public getJobManagerLeaderElectionService(jobID JobID) : LeaderElectionService from class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices to public getJobManagerLeaderElectionService(jobID JobID) : LeaderElectionService from class org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices | From | To | |
| Extract Subclass | 1 | ||
| Extract Subclass org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices from class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type notificationsDispatcher : ExecutorService to notificationsDispatcher : Executor in method public EmbeddedLeaderService(notificationsDispatcher Executor) in class org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService | From | To | |
| Rename Variable | 1 | ||
| Rename Variable protocol : String to protocolPrefix : String in method public getRpcUrl(hostname String, port int, endpointName String, addressResolution HighAvailabilityServicesUtils.AddressResolution, akkaProtocol AkkaProtocol) : String in class org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils | From | To | |
| Inline Method | 1 | ||
| Inline Method public createLeaderRetrievalService(configuration Configuration, resolveInitialHostName boolean) : StandaloneLeaderRetrievalService inlined to public createLeaderRetrievalService(configuration Configuration) : StandaloneLeaderRetrievalService in class org.apache.flink.runtime.util.StandaloneUtils | From | To | |
| Push Down Attribute | 1 | ||
| Push Down Attribute private jobManagerLeaderServices : HashMap<JobID,EmbeddedLeaderService> from class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices to private jobManagerLeaderServices : HashMap<JobID,EmbeddedLeaderService> from class org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices | From | To | |
| Move And Rename Class | 5 | ||
| Move And Rename Class org.apache.flink.runtime.rpc.RpcServiceUtils moved and renamed to org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils | From | To | |
| Move And Rename Class org.apache.flink.runtime.highavailability.nonha.NonHaRegistry moved and renamed to org.apache.flink.runtime.highavailability.nonha.standalone.StandaloneRunningJobsRegistry | From | To | |
| Move And Rename Class org.apache.flink.runtime.highavailability.ZookeeperRegistry moved and renamed to org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperRunningJobsRegistry | From | To | |
| Move And Rename Class org.apache.flink.runtime.highavailability.ZookeeperHaServices moved and renamed to org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperHaServices | From | To | |
| Move And Rename Class org.apache.flink.runtime.highavailability.NonHaServices moved and renamed to org.apache.flink.runtime.highavailability.nonha.standalone.StandaloneHaServices | From | To | |
| Move Class | 5 | ||
| Move Class org.apache.flink.runtime.highavailability.leaderelection.SingleLeaderElectionServiceTest moved to org.apache.flink.runtime.highavailability.nonha.leaderelection.SingleLeaderElectionServiceTest | From | To | |
| Move Class org.apache.flink.runtime.highavailability.nonha.EmbeddedLeaderService moved to org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService | From | To | |
| Move Class org.apache.flink.runtime.highavailability.leaderelection.SingleLeaderElectionService moved to org.apache.flink.runtime.highavailability.nonha.leaderelection.SingleLeaderElectionService | From | To | |
| Move Class org.apache.flink.runtime.resourcemanager.exceptions.ConfigurationException moved to org.apache.flink.util.ConfigurationException | From | To | |
| Move Class org.apache.flink.runtime.highavailability.ZooKeeperRegistryTest moved to org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperRegistryTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type runningJobsRegistry : NonHaRegistry to runningJobsRegistry : RunningJobsRegistry in class org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices | From | To |