|
Change Variable Type buffer : NetworkBuffer to buffer : Buffer in method public run() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler.BufferListenerTask |
From |
To |
|
Change Variable Type buffer : NetworkBuffer to buffer : Buffer in method private decodeBufferOrEvent(inputChannel RemoteInputChannel, bufferOrEvent NettyMessage.BufferResponse) : void in class org.apache.flink.runtime.io.network.netty.CreditBasedClientHandler |
From |
To |
|
Change Variable Type buffer1 : NetworkBuffer to buffer1 : Buffer in method public testWriteRead() : void in class org.apache.flink.runtime.io.disk.iomanager.BufferFileWriterFileSegmentReaderTest |
From |
To |
|
Change Variable Type buffer : NetworkBuffer to buffer : Buffer in method private decodeBufferOrEvent(inputChannel RemoteInputChannel, bufferOrEvent NettyMessage.BufferResponse, isStagedBuffer boolean) : boolean in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler |
From |
To |
|
Change Variable Type eventBuffer : NetworkBuffer to eventBuffer : Buffer in method public testForwardsIsBuffer() : void in class org.apache.flink.runtime.io.network.buffer.ReadOnlySlicedBufferTest |
From |
To |
|
Rename Parameter length : int to contentLength : int in method private allocateBuffer(allocator ByteBufAllocator, id byte, messageHeaderLength int, contentLength int, allocateForContent boolean) : ByteBuf in class org.apache.flink.runtime.io.network.netty.NettyMessage |
From |
To |
|
Rename Parameter length : int to contentLength : int in method private allocateBuffer(allocator ByteBufAllocator, id byte, contentLength int) : ByteBuf in class org.apache.flink.runtime.io.network.netty.NettyMessage |
From |
To |
|
Rename Parameter retainedSlice : ByteBuf to buffer : ByteBuf in method private BufferResponse(buffer ByteBuf, isBuffer boolean, sequenceNumber int, receiverId InputChannelID, backlog int) in class org.apache.flink.runtime.io.network.netty.NettyMessage.BufferResponse |
From |
To |