|
Move Method package notifyCreditAvailable(inputChannel RemoteInputChannel) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedClientHandler to package notifyCreditAvailable(inputChannel RemoteInputChannel) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler |
From |
To |
|
Move Method public userEventTriggered(ctx ChannelHandlerContext, msg Object) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedClientHandler to public userEventTriggered(ctx ChannelHandlerContext, msg Object) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler |
From |
To |
|
Move Method private writeAndFlushNextMessageIfPossible(channel Channel) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedClientHandler to private writeAndFlushNextMessageIfPossible(channel Channel) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler |
From |
To |
|
Move Method public channelWritabilityChanged(ctx ChannelHandlerContext) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedClientHandler to public channelWritabilityChanged(ctx ChannelHandlerContext) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler |
From |
To |
|
Change Return Type boolean to void in method private decodeBufferOrEvent(inputChannel RemoteInputChannel, bufferOrEvent NettyMessage.BufferResponse) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler |
From |
To |
|
Change Return Type ResultSubpartition.BufferAndBacklog to BufferAndBacklog in method public getNextBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueueTest.DefaultBufferResultSubpartitionView |
From |
To |
|
Change Return Type ResultSubpartition.BufferAndBacklog to BufferAndBacklog in method public getNextBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueueTest.NoOpResultSubpartitionView |
From |
To |
|
Change Return Type boolean to void in method private decodeMsg(msg Object) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler |
From |
To |
|
Change Return Type ResultSubpartition.BufferAndBacklog to BufferAndBacklog in method public getNextBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueueTest.ReadOnlyBufferResultSubpartitionView |
From |
To |
|
Change Variable Type client : CreditBasedClientHandler to client : PartitionRequestClientHandler in method public testReceiveEmptyBuffer() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest |
From |
To |
|
Change Variable Type handler : CreditBasedClientHandler to handler : PartitionRequestClientHandler in method public testThrowExceptionForNoAvailableBuffer() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest |
From |
To |
|
Change Variable Type handler : CreditBasedClientHandler to handler : PartitionRequestClientHandler in method public testNotifyCreditAvailableAfterReleased() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest |
From |
To |
|
Change Variable Type handler : CreditBasedClientHandler to handler : PartitionRequestClientHandler in method public testReceiveBuffer() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest |
From |
To |
|
Change Variable Type handler : CreditBasedClientHandler to handler : PartitionRequestClientHandler in method public testNotifyCreditAvailable() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest |
From |
To |
|
Extract And Move Method package blockChannel(channel EmbeddedChannel) : ByteBuf extracted from public testNotifyCreditAvailable() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest & moved to class org.apache.flink.runtime.io.network.netty.PartitionRequestQueueTest |
From |
To |
|
Extract And Move Method public setupPartition(partition ResultPartition) : void extracted from protected createResultPartition(jobId JobID, partitionId ResultPartitionID, environment NetworkEnvironment, channels int) : ResultPartitionWriter in class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment & moved to class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |
|
Extract And Move Method public setupInputGate(gate SingleInputGate) : void extracted from private createInputGate(jobId JobID, dataSetID IntermediateDataSetID, executionAttemptID ExecutionAttemptID, senderLocation TaskManagerLocation, environment NetworkEnvironment, channels int) : InputGate in class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment & moved to class org.apache.flink.runtime.io.network.NetworkEnvironment |
From |
To |