public class ResultPartitionFactory extends Object
ResultPartition
to use in NettyShuffleEnvironment
.Constructor and Description |
---|
ResultPartitionFactory(ResultPartitionManager partitionManager,
FileChannelManager channelManager,
BufferPoolFactory bufferPoolFactory,
BoundedBlockingSubpartitionType blockingSubpartitionType,
int networkBuffersPerChannel,
int floatingNetworkBuffersPerGate,
int networkBufferSize,
boolean forcePartitionReleaseOnConsumption,
boolean blockingShuffleCompressionEnabled,
String compressionCodec,
int maxBuffersPerChannel) |
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,
FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory) |
public ResultPartitionFactory(ResultPartitionManager partitionManager, FileChannelManager channelManager, BufferPoolFactory bufferPoolFactory, BoundedBlockingSubpartitionType blockingSubpartitionType, int networkBuffersPerChannel, int floatingNetworkBuffersPerGate, int networkBufferSize, boolean forcePartitionReleaseOnConsumption, boolean blockingShuffleCompressionEnabled, String compressionCodec, int maxBuffersPerChannel)
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, FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.