2ccb5fdb47aa0e3766fd7fbd17a41feaca29fcbc
Files Diff
- Added: 4
- Removed: 0
- Renamed: 0
- Modified: 46
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method private sendFailIntermediateResultPartitionsRPCCall() : void renamed to private sendFailIntermediateResultPartitionsRpcCall() : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Rename Method private sendUpdateTaskRpcCall(consumerSlot SimpleSlot, updateTaskMsg UpdatePartitionInfo) : void renamed to private sendUpdatePartitionInfoRpcCall(consumerSlot SimpleSlot, updatePartitionInfo UpdatePartitionInfo) : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method public getPath() : String from class org.apache.flink.runtime.instance.Instance to public path() : String from class org.apache.flink.runtime.instance.AkkaInstanceGateway | From | To | |
| Change Parameter Type | 3 | ||
| Change Parameter Type taskManager : ActorRef to gateway : InstanceGateway in method public getInstance(gateway InstanceGateway) : Instance in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils | From | To | |
| Change Parameter Type taskManager : ActorRef to gateway : InstanceGateway in method public getInstance(gateway InstanceGateway, numberOfSlots int) : Instance in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils | From | To | |
| Change Parameter Type taskManager : ActorRef to instanceGateway : InstanceGateway in method public Instance(instanceGateway InstanceGateway, connectionInfo InstanceConnectionInfo, id InstanceID, resources HardwareDescription, numberOfSlots int) in class org.apache.flink.runtime.instance.Instance | From | To | |
| Rename Variable | 1 | ||
| Rename Variable taskManager : ActorRef to gateway : InstanceGateway in method public sendMessageToCurrentExecution(message Serializable, attemptID ExecutionAttemptID) : void in class org.apache.flink.runtime.executiongraph.ExecutionVertex | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private taskManager : ActorRef from class org.apache.flink.runtime.instance.Instance to private taskManager : ActorRef from class org.apache.flink.runtime.instance.AkkaInstanceGateway | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute taskManager : ActorRef to instanceGateway : InstanceGateway in class org.apache.flink.runtime.instance.Instance | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type taskManager : ActorRef to gateway : InstanceGateway in method public sendMessageToCurrentExecution(message Serializable, attemptID ExecutionAttemptID) : void in class org.apache.flink.runtime.executiongraph.ExecutionVertex | From | To | |
| Extract Method | 1 | ||
| Extract Method public getExecutionVertex(id JobVertexID, executionContext ExecutionContext) : ExecutionJobVertex extracted from public getExecutionVertex(id JobVertexID) : ExecutionJobVertex in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type taskManager : ActorRef to instanceGateway : InstanceGateway in class org.apache.flink.runtime.instance.Instance | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter updateTaskMsg : UpdatePartitionInfo to updatePartitionInfo : UpdatePartitionInfo in method private sendUpdatePartitionInfoRpcCall(consumerSlot SimpleSlot, updatePartitionInfo UpdatePartitionInfo) : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Rename Parameter taskManager : ActorRef to gateway : InstanceGateway in method public getInstance(gateway InstanceGateway) : Instance in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils | From | To | |
| Rename Parameter taskManager : ActorRef to gateway : InstanceGateway in method public getInstance(gateway InstanceGateway, numberOfSlots int) : Instance in class org.apache.flink.runtime.executiongraph.ExecutionGraphTestUtils | From | To | |
| Rename Parameter taskManager : ActorRef to instanceGateway : InstanceGateway in method public Instance(instanceGateway InstanceGateway, connectionInfo InstanceConnectionInfo, id InstanceID, resources HardwareDescription, numberOfSlots int) in class org.apache.flink.runtime.instance.Instance | From | To |