d72a3f7f99a7e242b191e993ced123d98a083d14
Files Diff
- Added: 4
- Removed: 3
- Renamed: 0
- Modified: 11
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public requestIntermediateResultPartition(partitionId ResultPartitionID, requestedQueueIndex int, inputChannel RemoteInputChannel) : void renamed to public requestSubpartition(partitionId ResultPartitionID, requestedQueueIndex int, inputChannel RemoteInputChannel) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClient | From | To | |
| Rename Method private checkIoError() : void renamed to private checkError() : void in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To | |
| Move Class | 3 | ||
| Move Class org.apache.flink.runtime.io.network.util.TestSingleInputGate moved to org.apache.flink.runtime.io.network.partition.consumer.TestSingleInputGate | From | To | |
| Move Class org.apache.flink.runtime.io.network.util.TestInputChannel moved to org.apache.flink.runtime.io.network.partition.consumer.TestInputChannel | From | To | |
| Move Class org.apache.flink.runtime.io.network.api.reader.IteratorWrappingTestSingleInputGate moved to org.apache.flink.runtime.io.network.partition.consumer.IteratorWrappingTestSingleInputGate | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute producerAddress : ConnectionID to connectionId : ConnectionID in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To | |
| Extract Variable | 1 | ||
| Extract Variable t : Throwable in method private checkError() : void from class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter error : Throwable to cause : Throwable in method public onError(cause Throwable) : void in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To | |
| Rename Parameter producerAddress : ConnectionID to connectionId : ConnectionID in method package RemoteInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, connectionId ConnectionID, connectionManager ConnectionManager) in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To | |
| Rename Parameter gate : SingleInputGate to inputGate : SingleInputGate in method package RemoteInputChannel(inputGate SingleInputGate, channelIndex int, partitionId ResultPartitionID, connectionId ConnectionID, connectionManager ConnectionManager) in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To |