92ff2b152cac3ad6a53373c0c022579306051133
Files Diff
- Added: 37
- Removed: 3
- Renamed: 0
- Modified: 51
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public getNumberOfSlots() : int renamed to public totalNumberOfSlots() : int in class org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse | From | To | |
| Rename Method public getNumberOfTaskManagers() : int renamed to public numRegisteredTaskManagers() : int in class org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse | From | To | |
| Rename Variable | 5 | ||
| Rename Variable i2 : InstanceID to instanceID2 : InstanceID in method public testReportHeartbeat() : void in class org.apache.flink.runtime.instance.InstanceManagerTest | From | To | |
| Rename Variable i3 : InstanceID to instanceID3 : InstanceID in method public testReportHeartbeat() : void in class org.apache.flink.runtime.instance.InstanceManagerTest | From | To | |
| Rename Variable host : Instance to instance : Instance in method public unregisterTaskManager(instanceID ActorRef, terminated boolean) : void in class org.apache.flink.runtime.instance.InstanceManager | From | To | |
| Rename Variable i1 : InstanceID to instanceID1 : InstanceID in method public testReportHeartbeat() : void in class org.apache.flink.runtime.instance.InstanceManagerTest | From | To | |
| Rename Variable id : InstanceID to instanceID : InstanceID in method public registerTaskManager(taskManager ActorRef, resourceID ResourceID, connectionInfo InstanceConnectionInfo, resources HardwareDescription, numberOfSlots int, leaderSessionID UUID) : InstanceID in class org.apache.flink.runtime.instance.InstanceManager | From | To | |
| Change Return Type | 1 | ||
| Change Return Type FlinkYarnClusterStatus to GetClusterStatusResponse in method public abstract getClusterStatus() : GetClusterStatusResponse in class org.apache.flink.runtime.yarn.AbstractFlinkYarnCluster | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.runtime.yarn.FlinkYarnClusterStatus moved and renamed to org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute numberOfSlots : int to totalNumberOfSlots : int in class org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse | From | To | |
| Rename Attribute numberOfTaskManagers : int to numRegisteredTaskManagers : int in class org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type that : FlinkYarnClusterStatus to that : GetClusterStatusResponse in method public equals(o Object) : boolean in class org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse | From | To | |
| Change Variable Type status : FlinkYarnClusterStatus to status : GetClusterStatusResponse in method protected getClient(options CommandLineOptions, programName String, userParallelism int, detachedMode boolean) : Client in class org.apache.flink.client.CliFrontend | From | To | |
| Change Variable Type status : FlinkYarnClusterStatus to status : GetClusterStatusResponse in method public runInteractiveCli(yarnCluster AbstractFlinkYarnCluster) : void in class org.apache.flink.client.FlinkYarnSessionCli | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter numberOfSlots : int to totalNumberOfSlots : int in method public GetClusterStatusResponse(numRegisteredTaskManagers int, totalNumberOfSlots int) in class org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse | From | To | |
| Rename Parameter numberOfTaskManagers : int to numRegisteredTaskManagers : int in method public GetClusterStatusResponse(numRegisteredTaskManagers int, totalNumberOfSlots int) in class org.apache.flink.runtime.clusterframework.messages.GetClusterStatusResponse | From | To | |
| Rename Parameter taskManager : ActorRef to instanceID : ActorRef in method public unregisterTaskManager(instanceID ActorRef, terminated boolean) : void in class org.apache.flink.runtime.instance.InstanceManager | From | To | |
| Rename Parameter userCodeClassloader : ClassLoader to classloader : ClassLoader in method public deserializeError(classloader ClassLoader) : Throwable in class org.apache.flink.runtime.util.SerializedThrowable | From | To |