94c24723192e3a6e5a90eca579168724463f083c
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public fromEdges(edges ExecutionEdge[], consumerResourceId ResourceID, allowLazyDeployment boolean) : InputChannelDeploymentDescriptor[] renamed to private fromEdgeAndValidate(allowLazyDeployment boolean, edge ExecutionEdge) : InputChannelDeploymentDescriptor in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor | From | To | |
| Change Parameter Type | 3 | ||
| Change Parameter Type partitionInfo : PartialInputChannelDeploymentDescriptor to partitionInfo : PartitionInfo in method package cachePartitionInfo(partitionInfo PartitionInfo) : void in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Parameter Type partitionInfo : PartialInputChannelDeploymentDescriptor to partitionInfo : PartitionInfo in method package cachePartitionInfo(partitionInfo PartitionInfo) : void in class org.apache.flink.runtime.executiongraph.ExecutionVertex | From | To | |
| Change Parameter Type edges : ExecutionEdge[] to edge : ExecutionEdge in method public fromEdge(edge ExecutionEdge) : InputChannelDeploymentDescriptor in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor | From | To | |
| Change Return Type | 1 | ||
| Change Return Type InputChannelDeploymentDescriptor[] to InputChannelDeploymentDescriptor in method private fromEdgeAndValidate(allowLazyDeployment boolean, edge ExecutionEdge) : InputChannelDeploymentDescriptor in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute partialInputChannelDeploymentDescriptors : ConcurrentLinkedQueue<PartialInputChannelDeploymentDescriptor> to partitionInfos : Collection<PartitionInfo> in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type desc : InputChannelDeploymentDescriptor[] to desc : List<InputChannelDeploymentDescriptor> in method public testUnknownChannelWithoutLazyDeploymentThrows() : void in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptorTest | From | To | |
| Change Variable Type partitions : InputChannelDeploymentDescriptor[] to partitions : List<InputChannelDeploymentDescriptor> in method package createDeploymentDescriptor(executionId ExecutionAttemptID, targetSlot LogicalSlot, taskRestore JobManagerTaskRestore, attemptNumber int) : TaskDeploymentDescriptor in class org.apache.flink.runtime.executiongraph.ExecutionVertex | From | To | |
| Change Variable Type desc : InputChannelDeploymentDescriptor[] to desc : List<InputChannelDeploymentDescriptor> in method public testMixedLocalRemoteUnknownDeployment() : void in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptorTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type partialInputChannelDeploymentDescriptors : ConcurrentLinkedQueue<PartialInputChannelDeploymentDescriptor> to partitionInfos : Collection<PartitionInfo> in class org.apache.flink.runtime.executiongraph.Execution | From | To | |
| Extract Method | 2 | ||
| Extract Method public fromEdge(edge ExecutionEdge) : InputChannelDeploymentDescriptor extracted from public fromEdges(edges ExecutionEdge[], consumerResourceId ResourceID, allowLazyDeployment boolean) : InputChannelDeploymentDescriptor[] in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor | From | To | |
| Extract Method private createKnownResultPartitionLocation(consumerResourceId ResourceID, consumedPartition IntermediateResultPartition, partitionTaskManagerLocation TaskManagerLocation) : ResultPartitionLocation extracted from public fromEdges(edges ExecutionEdge[], consumerResourceId ResourceID, allowLazyDeployment boolean) : InputChannelDeploymentDescriptor[] in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public fromEdge(edge ExecutionEdge) : InputChannelDeploymentDescriptor extracted from package scheduleOrUpdateConsumers(allConsumers List<List<ExecutionEdge>>) : void in class org.apache.flink.runtime.executiongraph.Execution & moved to class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter edges : ExecutionEdge[] to edge : ExecutionEdge in method public fromEdge(edge ExecutionEdge) : InputChannelDeploymentDescriptor in class org.apache.flink.runtime.deployment.InputChannelDeploymentDescriptor | From | To |