client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java [35:76]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class RemoteShuffleResultPartitionFactory
    extends AbstractRemoteShuffleResultPartitionFactory {

  public RemoteShuffleResultPartitionFactory(
      CelebornConf celebornConf,
      ResultPartitionManager partitionManager,
      BufferPoolFactory bufferPoolFactory,
      int networkBufferSize) {
    super(celebornConf, partitionManager, bufferPoolFactory, networkBufferSize);
  }

  @Override
  public ResultPartition createRemoteShuffleResultPartitionInternal(
      String taskNameWithSubtaskAndId,
      int partitionIndex,
      ResultPartitionID id,
      ResultPartitionType type,
      int numSubpartitions,
      int maxParallelism,
      List<SupplierWithException<BufferPool, IOException>> bufferPoolFactories,
      CelebornConf celebornConf,
      int numMappers,
      BufferCompressor bufferCompressor,
      RemoteShuffleDescriptor rsd) {
    return new RemoteShuffleResultPartition(
        taskNameWithSubtaskAndId,
        partitionIndex,
        id,
        type,
        numSubpartitions,
        maxParallelism,
        networkBufferSize,
        partitionManager,
        bufferCompressor,
        bufferPoolFactories.get(0),
        new RemoteShuffleOutputGate(
            rsd,
            numSubpartitions,
            networkBufferSize,
            bufferPoolFactories.get(1),
            celebornConf,
            numMappers));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java [35:77]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
public class RemoteShuffleResultPartitionFactory
    extends AbstractRemoteShuffleResultPartitionFactory {

  public RemoteShuffleResultPartitionFactory(
      CelebornConf celebornConf,
      ResultPartitionManager partitionManager,
      BufferPoolFactory bufferPoolFactory,
      int networkBufferSize) {

    super(celebornConf, partitionManager, bufferPoolFactory, networkBufferSize);
  }

  @Override
  public ResultPartition createRemoteShuffleResultPartitionInternal(
      String taskNameWithSubtaskAndId,
      int partitionIndex,
      ResultPartitionID id,
      ResultPartitionType type,
      int numSubpartitions,
      int maxParallelism,
      List<SupplierWithException<BufferPool, IOException>> bufferPoolFactories,
      CelebornConf celebornConf,
      int numMappers,
      BufferCompressor bufferCompressor,
      RemoteShuffleDescriptor rsd) {
    return new RemoteShuffleResultPartition(
        taskNameWithSubtaskAndId,
        partitionIndex,
        id,
        type,
        numSubpartitions,
        maxParallelism,
        networkBufferSize,
        partitionManager,
        bufferCompressor,
        bufferPoolFactories.get(0),
        new RemoteShuffleOutputGate(
            rsd,
            numSubpartitions,
            networkBufferSize,
            bufferPoolFactories.get(1),
            celebornConf,
            numMappers));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -