|
Change Parameter Type reader : SequenceNumberingViewReader to reader : NetworkSequenceViewReader in method package notifyReaderNonEmpty(reader NetworkSequenceViewReader) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Change Parameter Type clientHandler : PartitionRequestClientHandler to clientHandler : NetworkClientHandler in method private addInputChannel(clientHandler NetworkClientHandler) : RemoteInputChannel in class org.apache.flink.runtime.io.network.netty.ClientTransportErrorHandlingTest |
From |
To |
|
Change Parameter Type reader : SequenceNumberingViewReader to reader : NetworkSequenceViewReader in method private enqueueAvailableReader(reader NetworkSequenceViewReader) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Change Parameter Type partitionRequestHandler : PartitionRequestClientHandler to clientHandler : NetworkClientHandler in method package PartitionRequestClient(tcpChannel Channel, clientHandler NetworkClientHandler, connectionId ConnectionID, clientFactory PartitionRequestClientFactory) in class org.apache.flink.runtime.io.network.netty.PartitionRequestClient |
From |
To |
|
Change Parameter Type reader : SequenceNumberingViewReader to reader : NetworkSequenceViewReader in method public notifyReaderCreated(reader NetworkSequenceViewReader) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Move Method public userEventTriggered(ctx ChannelHandlerContext, msg Object) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler to public userEventTriggered(ctx ChannelHandlerContext, msg Object) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler |
From |
To |
|
Move Method public testThrowExceptionForNoAvailableBuffer() : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest to public testThrowExceptionForNoAvailableBuffer() : void from class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandlerTest |
From |
To |
|
Move Method package getNumBuffersAvailable() : long from class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader to package getNumBuffersAvailable() : long from class org.apache.flink.runtime.io.network.netty.CreditBasedSequenceNumberingViewReader |
From |
To |
|
Move Method package getNumCreditsAvailable() : int from class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader to package getNumCreditsAvailable() : int from class org.apache.flink.runtime.io.network.netty.CreditBasedSequenceNumberingViewReader |
From |
To |
|
Move Method public setRegisteredAsAvailable(isRegisteredAvailable boolean) : void from class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader to public setRegisteredAsAvailable(isRegisteredAvailable boolean) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedSequenceNumberingViewReader |
From |
To |
|
Move Method public testNotifyCreditAvailable() : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest to public testNotifyCreditAvailable() : void from class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandlerTest |
From |
To |
|
Move Method public testNotifyCreditAvailableAfterReleased() : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandlerTest to public testNotifyCreditAvailableAfterReleased() : void from class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandlerTest |
From |
To |
|
Move Method private writeAndFlushNextMessageIfPossible(channel Channel) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler to private writeAndFlushNextMessageIfPossible(channel Channel) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler |
From |
To |
|
Move Method package notifyCreditAvailable(inputChannel RemoteInputChannel) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler to public notifyCreditAvailable(inputChannel RemoteInputChannel) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler |
From |
To |
|
Move Method private isAvailable(bufferAndBacklog BufferAndBacklog, remaining long) : boolean from class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader to private isAvailable(bufferAndBacklog BufferAndBacklog, remaining long) : boolean from class org.apache.flink.runtime.io.network.netty.CreditBasedSequenceNumberingViewReader |
From |
To |
|
Move Method public channelWritabilityChanged(ctx ChannelHandlerContext) : void from class org.apache.flink.runtime.io.network.netty.PartitionRequestClientHandler to public channelWritabilityChanged(ctx ChannelHandlerContext) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler |
From |
To |
|
Move Method public addCredit(creditDeltas int) : void from class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader to public addCredit(creditDeltas int) : void from class org.apache.flink.runtime.io.network.netty.CreditBasedSequenceNumberingViewReader |
From |
To |
|
Change Variable Type reader : SequenceNumberingViewReader to reader : CreditBasedSequenceNumberingViewReader in method public testEnqueueReaderByNotifyingEventBuffer() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueueTest |
From |
To |
|
Change Variable Type reader : SequenceNumberingViewReader to reader : CreditBasedSequenceNumberingViewReader in method public testEnqueueReaderByNotifyingBufferAndCredit() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueueTest |
From |
To |
|
Change Variable Type reader : SequenceNumberingViewReader to reader : NetworkSequenceViewReader in method private releaseAllResources() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Change Variable Type reader : SequenceNumberingViewReader to reader : NetworkSequenceViewReader in method private writeAndFlushNextMessageIfPossible(channel Channel) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Change Variable Type handler : PartitionRequestClientHandler to handler : NetworkClientHandler in method public testConnectionResetByPeer() : void in class org.apache.flink.runtime.io.network.netty.ClientTransportErrorHandlingTest |
From |
To |
|
Change Variable Type seqView : SequenceNumberingViewReader to seqView : CreditBasedSequenceNumberingViewReader in method public testProducerFailedException() : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueueTest |
From |
To |
|
Change Variable Type handler : PartitionRequestClientHandler to handler : NetworkClientHandler in method public testExceptionOnWrite() : void in class org.apache.flink.runtime.io.network.netty.ClientTransportErrorHandlingTest |
From |
To |
|
Change Variable Type handler : PartitionRequestClientHandler to handler : NetworkClientHandler in method public testExceptionOnRemoteClose() : void in class org.apache.flink.runtime.io.network.netty.ClientTransportErrorHandlingTest |
From |
To |
|
Change Variable Type reader : SequenceNumberingViewReader to reader : NetworkSequenceViewReader in method package addCredit(receiverId InputChannelID, credit int) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Change Variable Type handler : PartitionRequestClientHandler to handler : NetworkClientHandler in method public testChannelClosedOnExceptionDuringErrorNotification() : void in class org.apache.flink.runtime.io.network.netty.ClientTransportErrorHandlingTest |
From |
To |
|
Change Variable Type reader : SequenceNumberingViewReader to reader : NetworkSequenceViewReader in method public userEventTriggered(ctx ChannelHandlerContext, msg Object) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Change Variable Type handler : PartitionRequestClientHandler to handler : NetworkClientHandler in method public testExceptionCaught() : void in class org.apache.flink.runtime.io.network.netty.ClientTransportErrorHandlingTest |
From |
To |
|
Change Variable Type handler : PartitionRequestClientHandler to handler : NetworkClientHandler in method public testWrappingOfRemoteErrorMessage() : void in class org.apache.flink.runtime.io.network.netty.ClientTransportErrorHandlingTest |
From |
To |
|
Change Variable Type requestHandler : PartitionRequestClientHandler to clientHandler : NetworkClientHandler in method private handInChannel(channel Channel) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.ConnectingChannel |
From |
To |