Package 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

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, int hybridShuffleSpilledIndexRegionGroupSize, long hybridShuffleNumRetainedInMemoryRegionsMax, Optional<TieredResultPartitionFactory> tieredStorage)

Method Summary

Modifier and Type	Method	Description
ResultPartition	create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionDeploymentDescriptor desc)
ResultPartition	create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionID id, ResultPartitionType type, int numberOfSubpartitions, int maxParallelism, boolean isBroadcast, org.apache.flink.util.function.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,
                              int hybridShuffleSpilledIndexRegionGroupSize,
                              long hybridShuffleNumRetainedInMemoryRegionsMax,
                              Optional<TieredResultPartitionFactory> tieredStorage)

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,
                              boolean isBroadcast,
                              org.apache.flink.util.function.SupplierWithException<BufferPool,IOException> bufferPoolFactory)