dbe0e8286d76a5facdb49589b638b87dbde80178
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 9
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Push Down Method | 1 | ||
Push Down Method protected createYarnClusterClient(descriptor AbstractYarnClusterDescriptor, numberTaskManagers int, slotsPerTaskManager int, report ApplicationReport, flinkConfiguration Configuration, perJobCluster boolean) : YarnClusterClient from class org.apache.flink.yarn.AbstractYarnClusterDescriptor to protected createYarnClusterClient(descriptor AbstractYarnClusterDescriptor, numberTaskManagers int, slotsPerTaskManager int, report ApplicationReport, flinkConfiguration Configuration, perJobCluster boolean) : ClusterClient<ApplicationId> from class org.apache.flink.yarn.YarnClusterDescriptor | From | To | |
Change Parameter Type | 1 | ||
Change Parameter Type flinkConfiguration : org.apache.flink.configuration.Configuration to flinkConfiguration : Configuration in method protected createYarnClusterClient(descriptor AbstractYarnClusterDescriptor, numberTaskManagers int, slotsPerTaskManager int, report ApplicationReport, flinkConfiguration Configuration, perJobCluster boolean) : ClusterClient<ApplicationId> in class org.apache.flink.yarn.YarnClusterDescriptor | From | To | |
Rename Variable | 1 | ||
Rename Variable yarnClusterDescriptorV2 : YarnClusterDescriptorV2 to flip6YarnClusterDescriptor : Flip6YarnClusterDescriptor in method public testPerJobMode() : void in class org.apache.flink.yarn.YARNITCase | From | To | |
Change Return Type | 5 | ||
Change Return Type YarnClusterClient to ClusterClient<ApplicationId> in method public retrieve(applicationId ApplicationId) : ClusterClient<ApplicationId> in class org.apache.flink.yarn.AbstractYarnClusterDescriptor | From | To | |
Change Return Type YarnClusterClient to ClusterClient<ApplicationId> in method protected createYarnClusterClient(descriptor AbstractYarnClusterDescriptor, numberTaskManagers int, slotsPerTaskManager int, report ApplicationReport, flinkConfiguration Configuration, perJobCluster boolean) : ClusterClient<ApplicationId> in class org.apache.flink.yarn.YarnClusterDescriptor | From | To | |
Change Return Type YarnClusterClient to ClusterClient<ApplicationId> in method protected deployInternal(clusterSpecification ClusterSpecification, yarnClusterEntrypoint String, jobGraph JobGraph) : ClusterClient<ApplicationId> in class org.apache.flink.yarn.AbstractYarnClusterDescriptor | From | To | |
Change Return Type YarnClusterClient to ClusterClient<ApplicationId> in method public deploySessionCluster(clusterSpecification ClusterSpecification) : ClusterClient<ApplicationId> in class org.apache.flink.yarn.AbstractYarnClusterDescriptor | From | To | |
Change Return Type YarnClusterClient to ClusterClient<ApplicationId> in method public deployJobCluster(clusterSpecification ClusterSpecification, jobGraph JobGraph) : ClusterClient<ApplicationId> in class org.apache.flink.yarn.AbstractYarnClusterDescriptor | From | To | |
Rename Class | 1 | ||
Rename Class org.apache.flink.yarn.YarnClusterDescriptorV2 renamed to org.apache.flink.yarn.Flip6YarnClusterDescriptor | From | To | |
Extract Variable | 2 | ||
Extract Variable host : String in method public retrieve(applicationId ApplicationId) : ClusterClient<ApplicationId> from class org.apache.flink.yarn.AbstractYarnClusterDescriptor | From | To | |
Extract Variable rpcPort : int in method public retrieve(applicationId ApplicationId) : ClusterClient<ApplicationId> from class org.apache.flink.yarn.AbstractYarnClusterDescriptor | From | To | |
Change Variable Type | 2 | ||
Change Variable Type clusterClient : YarnClusterClient to clusterClient : ClusterClient<ApplicationId> in method public testPerJobMode() : void in class org.apache.flink.yarn.YARNITCase | From | To | |
Change Variable Type yarnClusterDescriptorV2 : YarnClusterDescriptorV2 to flip6YarnClusterDescriptor : Flip6YarnClusterDescriptor in method public testPerJobMode() : void in class org.apache.flink.yarn.YARNITCase | From | To |