|
Pull Up Method private decreaseBuffersInBacklog(buffer Buffer) : void from class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition to protected decreaseBuffersInBacklogUnsafe(buffer Buffer) : int from class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Pull Up Method public decreaseBuffersInBacklog(buffer Buffer) : int from class org.apache.flink.runtime.io.network.partition.SpillableSubpartition to protected decreaseBuffersInBacklogUnsafe(buffer Buffer) : int from class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Pull Up Method public getBuffersInBacklog() : int from class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition to public getBuffersInBacklog() : int from class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Pull Up Method private increaseBuffersInBacklog(buffer Buffer) : void from class org.apache.flink.runtime.io.network.partition.PipelinedSubpartition to protected increaseBuffersInBacklog(buffer Buffer) : void from class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Pull Up Method public getBuffersInBacklog() : int from class org.apache.flink.runtime.io.network.partition.SpillableSubpartition to public getBuffersInBacklog() : int from class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |
|
Pull Up Method private increaseBuffersInBacklog(buffer Buffer) : void from class org.apache.flink.runtime.io.network.partition.SpillableSubpartition to protected increaseBuffersInBacklog(buffer Buffer) : void from class org.apache.flink.runtime.io.network.partition.ResultSubpartition |
From |
To |