|
Change Return Type Buffer to BufferAndBacklog in method public getNextBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.partition.ResultSubpartitionView |
From |
To |
|
Change Return Type Buffer to BufferAndBacklog in method public getNextBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.netty.CancelPartitionRequestTest.InfiniteSubpartitionView |
From |
To |
|
Change Return Type Buffer to BufferAndBacklog in method package pollBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition |
From |
To |
|
Change Return Type Buffer to BufferAndBacklog in method public getNextBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionView |
From |
To |
|
Change Return Type Buffer to BufferAndBacklog in method public getNextBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionView |
From |
To |
|
Change Return Type Buffer to BufferAndBacklog in method public getNextBuffer() : BufferAndBacklog in class org.apache.flink.runtime.io.network.partition.PipelinedSubpartitionView |
From |
To |
|
Change Variable Type next : Buffer to next : BufferAndBacklog in method public getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.netty.SequenceNumberingViewReader |
From |
To |
|
Change Variable Type parent : ResultSubpartition to parent : SpillableSubpartition in method public testReadMultipleFilesWithSingleBufferPool() : void in class org.apache.flink.runtime.io.network.partition.SpilledSubpartitionViewTest |
From |
To |
|
Change Variable Type read : Buffer to read : BufferAndBacklog in method public testConsumeSpilledPartition() : void in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionTest |
From |
To |
|
Change Variable Type buffer : Buffer to bufferAndBacklog : BufferAndBacklog in method public call() : Boolean in class org.apache.flink.runtime.io.network.util.TestSubpartitionConsumer |
From |
To |
|
Change Variable Type read : Buffer to read : BufferAndBacklog in method public testConsumeSpillablePartitionSpilledDuringConsume() : void in class org.apache.flink.runtime.io.network.partition.SpillableSubpartitionTest |
From |
To |
|
Change Variable Type next : Buffer to next : BufferAndBacklog in method package getNextBuffer() : BufferAndAvailability in class org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel |
From |
To |