public class ResultPartitionFactory extends Object
ResultPartition
to use in NettyShuffleEnvironment
.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,
int hybridShuffleSpilledIndexSegmentSize,
long hybridShuffleNumRetainedInMemoryRegionsMax) |
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,
boolean isBroadcast,
SupplierWithException<BufferPool,IOException> bufferPoolFactory) |
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 hybridShuffleSpilledIndexSegmentSize, long hybridShuffleNumRetainedInMemoryRegionsMax)
public ResultPartition create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionDeploymentDescriptor desc)
@VisibleForTesting public ResultPartition create(String taskNameWithSubtaskAndId, int partitionIndex, ResultPartitionID id, ResultPartitionType type, int numberOfSubpartitions, int maxParallelism, boolean isBroadcast, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.