|
Pull Up Method public getPartitionId() : ResultPartitionID from class org.apache.flink.runtime.io.network.api.writer.RecordOrEventCollectingResultPartitionWriter to public getPartitionId() : ResultPartitionID from class org.apache.flink.runtime.io.network.api.writer.AbstractCollectingResultPartitionWriter |
From |
To |
|
Pull Up Method public getPartitionId() : ResultPartitionID from class org.apache.flink.runtime.io.network.api.writer.RecordCollectingResultPartitionWriter to public getPartitionId() : ResultPartitionID from class org.apache.flink.runtime.io.network.api.writer.AbstractCollectingResultPartitionWriter |
From |
To |
|
Pull Up Method public getBufferProvider() : BufferProvider from class org.apache.flink.runtime.io.network.api.writer.RecordOrEventCollectingResultPartitionWriter to public getBufferProvider() : BufferProvider from class org.apache.flink.runtime.io.network.api.writer.AbstractCollectingResultPartitionWriter |
From |
To |
|
Pull Up Method public getNumTargetKeyGroups() : int from class org.apache.flink.runtime.io.network.api.writer.RecordCollectingResultPartitionWriter to public getNumTargetKeyGroups() : int from class org.apache.flink.runtime.io.network.api.writer.AbstractCollectingResultPartitionWriter |
From |
To |
|
Pull Up Method public getBufferProvider() : BufferProvider from class org.apache.flink.runtime.io.network.api.writer.RecordCollectingResultPartitionWriter to public getBufferProvider() : BufferProvider from class org.apache.flink.runtime.io.network.api.writer.AbstractCollectingResultPartitionWriter |
From |
To |
|
Pull Up Method public getNumTargetKeyGroups() : int from class org.apache.flink.runtime.io.network.api.writer.RecordOrEventCollectingResultPartitionWriter to public getNumTargetKeyGroups() : int from class org.apache.flink.runtime.io.network.api.writer.AbstractCollectingResultPartitionWriter |
From |
To |
|
Pull Up Method public getNumberOfSubpartitions() : int from class org.apache.flink.runtime.io.network.api.writer.RecordCollectingResultPartitionWriter to public getNumberOfSubpartitions() : int from class org.apache.flink.runtime.io.network.api.writer.AbstractCollectingResultPartitionWriter |
From |
To |
|
Pull Up Method public getNumberOfSubpartitions() : int from class org.apache.flink.runtime.io.network.api.writer.RecordOrEventCollectingResultPartitionWriter to public getNumberOfSubpartitions() : int from class org.apache.flink.runtime.io.network.api.writer.AbstractCollectingResultPartitionWriter |
From |
To |