org.apache.flink.runtime.io.network.partition

Class ResultPartitionFactory

java.lang.Object

org.apache.flink.runtime.io.network.partition.ResultPartitionFactory

public class ResultPartitionFactory
extends Object

Factory for ResultPartition to use in NettyShuffleEnvironment.

Constructor Summary

Constructors

Constructor and Description

ResultPartitionFactory(ResultPartitionManager partitionManager, FileChannelManager channelManager, BufferPoolFactory bufferPoolFactory, BatchShuffleReadBufferPool batchShuffleReadBufferPool, ScheduledExecutorService batchShuffleReadIOExecutor, BoundedBlockingSubpartitionType blockingSubpartitionType, int configuredNetworkBuffersPerChannel, int floatingNetworkBuffersPerGate, int networkBufferSize, boolean batchShuffleCompressionEnabled, String compressionCodec, int maxBuffersPerChannel, int sortShuffleMinBuffers, int sortShuffleMinParallelism, boolean sslEnabled, int maxOverdraftBuffersPerGate)

Method Summary

Modifier and Type	Method and Description
ResultPartition	create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionDeploymentDescriptor desc)
ResultPartition	create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionID id, ResultPartitionType type, int numberOfSubpartitions, int maxParallelism, SupplierWithException<BufferPool,IOException> bufferPoolFactory)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResultPartitionFactory

public ResultPartitionFactory(ResultPartitionManager partitionManager,
                              FileChannelManager channelManager,
                              BufferPoolFactory bufferPoolFactory,
                              BatchShuffleReadBufferPool batchShuffleReadBufferPool,
                              ScheduledExecutorService batchShuffleReadIOExecutor,
                              BoundedBlockingSubpartitionType blockingSubpartitionType,
                              int configuredNetworkBuffersPerChannel,
                              int floatingNetworkBuffersPerGate,
                              int networkBufferSize,
                              boolean batchShuffleCompressionEnabled,
                              String compressionCodec,
                              int maxBuffersPerChannel,
                              int sortShuffleMinBuffers,
                              int sortShuffleMinParallelism,
                              boolean sslEnabled,
                              int maxOverdraftBuffersPerGate)

Method Detail

create

public ResultPartition create(String taskNameWithSubtaskAndId,
                              int partitionIndex,
                              ResultPartitionDeploymentDescriptor desc)

create

@VisibleForTesting
public ResultPartition create(String taskNameWithSubtaskAndId,
                                                 int partitionIndex,
                                                 ResultPartitionID id,
                                                 ResultPartitionType type,
                                                 int numberOfSubpartitions,
                                                 int maxParallelism,
                                                 SupplierWithException<BufferPool,IOException> bufferPoolFactory)