268867ce620a2c12879749db2ecb68bbe129cad5
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 9
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Attribute | 1 | ||
Rename Attribute availableBuffers : ArrayDeque<Buffer> to bufferQueue : AvailableBufferQueue in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To | |
Change Variable Type | 1 | ||
Change Variable Type client : PartitionRequestClientHandler to client : CreditBasedClientHandler in method public testReceiveEmptyBuffer() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest | From | To | |
Extract Variable | 1 | ||
Extract Variable needMoreBuffers : boolean in method public notifyBufferAvailable(buffer Buffer) : boolean from class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To | |
Change Attribute Type | 2 | ||
Change Attribute Type isWaitingForFloatingBuffers : AtomicBoolean to isWaitingForFloatingBuffers : boolean in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To | |
Change Attribute Type availableBuffers : ArrayDeque<Buffer> to bufferQueue : AvailableBufferQueue in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | From | To |