ceb890f1d54acbc62eeeb308be386dea3b2c457d
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public testPartitionNotFound() : void renamed to public testRemotePartitionNotFound() : void in class org.apache.flink.runtime.taskmanager.TaskManagerTest | From | To | |
| Pull Up Method | 1 | ||
| Pull Up Method private checkError() : void from class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel to protected checkError() : void from class org.apache.flink.runtime.io.network.partition.consumer.InputChannel | From | To | |
| Push Down Method | 1 | ||
| Push Down Method protected InputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID) from class org.apache.flink.runtime.io.network.partition.consumer.InputChannel to package LocalInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, partitionManager ResultPartitionManager, taskEventDispatcher TaskEventDispatcher, initialAndMaxBackoff Tuple2<Integer,Integer>) from class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel | From | To | |
| Extract And Move Method | 1 | ||
| Extract And Move Method protected setError(cause Throwable) : void extracted from public onError(cause Throwable) : void in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel & moved to class org.apache.flink.runtime.io.network.partition.consumer.InputChannel | From | To |