809e40dadad68232c68ac34a3d56bfb69a9396d3
Files Diff
- Added: 4
- Removed: 1
- Renamed: 0
- Modified: 25
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public setMockNetworkEnvironment(mockNetworkEnvironment boolean) : Builder renamed to public setNetworkEnvironment(optionalNetworkEnvironment NetworkEnvironment) : Builder in class org.apache.flink.runtime.taskexecutor.TaskSubmissionTestEnvironment.Builder | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type mockNetworkEnvironment : boolean to optionalNetworkEnvironment : NetworkEnvironment in method public setNetworkEnvironment(optionalNetworkEnvironment NetworkEnvironment) : Builder in class org.apache.flink.runtime.taskexecutor.TaskSubmissionTestEnvironment.Builder | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.runtime.io.network.netty.PartitionProducerStateChecker moved to org.apache.flink.runtime.taskexecutor.PartitionProducerStateChecker | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute taskActions : TaskActions to partitionProducerStateProvider : PartitionProducerStateProvider in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateBuilder | From | To | |
| Rename Attribute jobId : JobID to partitionProducerStateProvider : PartitionProducerStateProvider in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate | From | To | |
| Extract Variable | 1 | ||
| Extract Variable partitionUpdate : PartitionInfo in method public testUpdateTaskInputPartitionsFailure() : void from class org.apache.flink.runtime.taskexecutor.TaskExecutorSubmissionTest | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type jobId : JobID to partitionProducerStateProvider : PartitionProducerStateProvider in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate | From | To | |
| Change Attribute Type taskActions : TaskActions to partitionProducerStateProvider : PartitionProducerStateProvider in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGateBuilder | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method public updatePartitionInfo(consumerID ExecutionAttemptID, partitionInfo PartitionInfo) : boolean extracted from public updatePartitions(executionAttemptID ExecutionAttemptID, partitionInfos Iterable<PartitionInfo>, timeout Time) : CompletableFuture<Acknowledge> in class org.apache.flink.runtime.taskexecutor.TaskExecutor & moved to class org.apache.flink.runtime.io.network.NetworkEnvironment | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter mockNetworkEnvironment : boolean to optionalNetworkEnvironment : NetworkEnvironment in method public setNetworkEnvironment(optionalNetworkEnvironment NetworkEnvironment) : Builder in class org.apache.flink.runtime.taskexecutor.TaskSubmissionTestEnvironment.Builder | From | To |