2a18f0532b22edf8b821ef883598f4ee52367711
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 18
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public terminate() : CompletableFuture<?> renamed to public closeAsync() : CompletableFuture<Void> in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Rename Method public close() : void renamed to public closeAsync() : CompletableFuture<Void> in class org.apache.flink.runtime.minicluster.StandaloneMiniCluster | From | To | |
| Rename Method protected startResourceManagers(configuration Configuration, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, numResourceManagers int, resourceManagerRpcServices RpcService[], clusterInformation ClusterInformation) : ResourceManagerRunner[] renamed to protected startResourceManager(configuration Configuration, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, resourceManagerRpcService RpcService, clusterInformation ClusterInformation) : ResourceManagerRunner in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Rename Variable | 2 | ||
| Rename Variable dispatcher : MiniClusterJobDispatcher to currentDispatcherGateway : DispatcherGateway in method public executeJobBlocking(job JobGraph) : JobExecutionResult in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Rename Variable resourceManagerRunners : ResourceManagerRunner[] to resourceManagerRunner : ResourceManagerRunner in method protected startResourceManager(configuration Configuration, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, resourceManagerRpcService RpcService, clusterInformation ClusterInformation) : ResourceManagerRunner in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Return Type | 3 | ||
| Change Return Type void to CompletableFuture<Void> in method public closeAsync() : CompletableFuture<Void> in class org.apache.flink.runtime.minicluster.StandaloneMiniCluster | From | To | |
| Change Return Type ResourceManagerRunner[] to ResourceManagerRunner in method protected startResourceManager(configuration Configuration, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, resourceManagerRpcService RpcService, clusterInformation ClusterInformation) : ResourceManagerRunner in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Return Type CompletableFuture<?> to CompletableFuture<Void> in method public closeAsync() : CompletableFuture<Void> in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private configuration : Configuration from class org.apache.flink.runtime.minicluster.MiniClusterJobDispatcher to private configuration : Configuration from class org.apache.flink.runtime.minicluster.MiniClusterITCase | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute jobManagerRpcServices : RpcService[] to jobManagerRpcService : RpcService in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Rename Attribute jobDispatcher : MiniClusterJobDispatcher to dispatcher : StandaloneDispatcher in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type dispatcher : MiniClusterJobDispatcher to currentDispatcherGateway : DispatcherGateway in method public executeJobBlocking(job JobGraph) : JobExecutionResult in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Variable Type resourceManagerRunners : ResourceManagerRunner[] to resourceManagerRunner : ResourceManagerRunner in method protected startResourceManager(configuration Configuration, haServices HighAvailabilityServices, heartbeatServices HeartbeatServices, metricRegistry MetricRegistry, resourceManagerRpcService RpcService, clusterInformation ClusterInformation) : ResourceManagerRunner in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Extract Variable | 3 | ||
| Extract Variable jobManagerRpcService : RpcService in method public start() : void from class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Extract Variable configuration : Configuration in method private startFlip6MiniCluster() : JobExecutorService from class org.apache.flink.test.util.MiniClusterResource | From | To | |
| Extract Variable resourceManagerRpcService : RpcService in method public start() : void from class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Split Attribute | 1 | ||
| Split Attribute cluster : StandaloneMiniCluster to [hostname : String, port : int] in class org.apache.flink.test.operators.RemoteEnvironmentITCase | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type jobManagerRpcServices : RpcService[] to jobManagerRpcService : RpcService in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Change Attribute Type jobDispatcher : MiniClusterJobDispatcher to dispatcher : StandaloneDispatcher in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Extract Method | 2 | ||
| Extract Method private getDispatcherGateway() : DispatcherGateway extracted from public runDetached(job JobGraph) : void in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Extract Method private getDispatcherGateway() : DispatcherGateway extracted from public executeJobBlocking(job JobGraph) : JobExecutionResult in class org.apache.flink.runtime.minicluster.MiniCluster | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public toJobExecutionResult(classLoader ClassLoader) : JobExecutionResult extracted from protected submitJob(jobGraph JobGraph, classLoader ClassLoader) : JobSubmissionResult in class org.apache.flink.client.program.rest.RestClusterClient & moved to class org.apache.flink.runtime.jobmaster.JobResult | From | To |