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 |