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) |
Modifier and Type | Method and Description |
---|---|
ResultPartition |
create(String taskNameWithSubtaskAndId,
ResultPartitionDeploymentDescriptor desc) |
ResultPartition |
create(String taskNameWithSubtaskAndId,
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)
public ResultPartition create(String taskNameWithSubtaskAndId, ResultPartitionDeploymentDescriptor desc)
@VisibleForTesting public ResultPartition create(String taskNameWithSubtaskAndId, ResultPartitionID id, ResultPartitionType type, int numberOfSubpartitions, int maxParallelism, FunctionWithException<BufferPoolOwner,BufferPool,IOException> bufferPoolFactory)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.