|
Change Variable Type buffer : Buffer to next : BufferAndAvailability in method private writeAndFlushNextMessageIfPossible(channel Channel) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Change Variable Type listener : EventListener<InputGate> to listener : InputGateListener in method private queueChannel(channel InputChannel) : void in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Variable Type listener : NotificationListener to reader : PipelinedSubpartitionView in method public add(buffer Buffer) : boolean in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Change Variable Type curr : SequenceNumberingSubpartitionView to reader : SequenceNumberingViewReader in method public userEventTriggered(ctx ChannelHandlerContext, msg Object) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Change Variable Type listener : NotificationListener to reader : PipelinedSubpartitionView in method public finish() : void in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Rename Variable resp : BufferResponse to msg : BufferResponse in method private writeAndFlushNextMessageIfPossible(channel Channel) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Rename Variable listener : NotificationListener to reader : PipelinedSubpartitionView in method public add(buffer Buffer) : boolean in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Rename Variable listener : NotificationListener to reader : PipelinedSubpartitionView in method public finish() : void in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Rename Variable buffer : Buffer to next : BufferAndAvailability in method private writeAndFlushNextMessageIfPossible(channel Channel) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Rename Variable buffer : Buffer to next : Buffer in method public getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader |
From |
To |
|
Rename Variable curr : SequenceNumberingSubpartitionView to reader : SequenceNumberingViewReader in method public userEventTriggered(ctx ChannelHandlerContext, msg Object) : void in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Rename Variable buffer : Buffer to next : Buffer in method package getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel |
From |
To |
|
Change Return Type Buffer to BufferAndAvailability in method package getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |
|
Change Return Type Buffer to BufferAndAvailability in method package getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel |
From |
To |
|
Change Return Type Buffer to BufferAndAvailability in method package abstract getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.partition.consumer.InputChannel |
From |
To |
|
Change Return Type Buffer to BufferAndAvailability in method public getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader |
From |
To |
|
Change Return Type Buffer to BufferAndAvailability in method public getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.partition.consumer.UnknownInputChannel |
From |
To |
|
Change Return Type int to long in method protected getTotalNumberOfBuffers() : long in class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Rename Attribute queue : Queue<SequenceNumberingSubpartitionView> to nonEmptyReader : Queue<SequenceNumberingViewReader> in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |
|
Rename Attribute registeredListener : EventListener<InputGate> to inputGateListener : InputGateListener in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Rename Attribute asyncFileReader : BufferFileReader to fileReader : BufferFileReader in class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionView |
From |
To |
|
Rename Attribute requestLock : Object to requestReleaseLock : Object in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |
|
Rename Attribute queueIterator : ResultSubpartitionView to subpartitionView : ResultSubpartitionView in class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader |
From |
To |
|
Rename Attribute currentQueuePosition : int to nextBuffer : Buffer in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionView |
From |
To |
|
Change Attribute Type registeredListener : EventListener<InputGate> to inputGateListener : InputGateListener in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Attribute Type isReleased : boolean to isReleased : AtomicBoolean in class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionView |
From |
To |
|
Change Attribute Type inputChannelsWithData : BlockingQueue<InputChannel> to inputChannelsWithData : ArrayDeque<InputChannel> in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Attribute Type totalNumberOfBuffers : int to totalNumberOfBuffers : long in class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Change Attribute Type buffers : ArrayList<Buffer> to buffers : ArrayDeque<Buffer> in class org.apache.flink.runtime.io.network.partition.SpillableSubpartition |
From |
To |
|
Change Attribute Type spilledView : ResultSubpartitionView to spilledView : SpilledSubpartitionView in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionView |
From |
To |
|
Change Attribute Type currentQueuePosition : int to nextBuffer : Buffer in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionView |
From |
To |
|
Change Attribute Type queue : Queue<SequenceNumberingSubpartitionView> to nonEmptyReader : Queue<SequenceNumberingViewReader> in class org.apache.flink.runtime.io.network.netty.PartitionRequestQueue |
From |
To |