2a65b62216e8fb73fce65209bf646ca67e5f96b0
Files Diff
- Added: 7
- Removed: 0
- Renamed: 0
- Modified: 14
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Inline Method | 1 | ||
| Move And Inline Method public setClientChannelPipeline(channelPipeline ChannelPipeline) : void moved from class org.apache.flink.runtime.io.network.netty.PartitionRequestProtocol to class org.apache.flink.runtime.io.network.netty.NettyClient & inlined to package init(protocol NettyProtocol) : void | From | To | |
| Change Return Type | 1 | ||
| Change Return Type void to ChannelFuture in method public requestSubpartition(partitionId ResultPartitionID, subpartitionIndex int, inputChannel RemoteInputChannel, delayMs int) : ChannelFuture in class org.apache.flink.runtime.io.network.netty.PartitionRequestClient | From | To | |
| Extract Variable | 3 | ||
| Extract Variable f : ChannelFuture in method public requestSubpartition(partitionId ResultPartitionID, subpartitionIndex int, inputChannel RemoteInputChannel, delayMs int) : ChannelFuture from class org.apache.flink.runtime.io.network.netty.PartitionRequestClient | From | To | |
| Extract Variable serialized : ByteBuf in method public write(ctx ChannelHandlerContext, msg Object, promise ChannelPromise) : void from class org.apache.flink.runtime.io.network.netty.NettyMessage.NettyMessageEncoder | From | To | |
| Extract Variable ctx : ChannelHandlerContext in method public testReceivePartitionNotFoundException() : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest | From | To |