public class TieredResultPartitionFactory extends Object
TieredResultPartitionFactory
contains the components to set up tiered storage.Constructor and Description |
---|
TieredResultPartitionFactory(TieredStorageConfiguration tieredStorageConfiguration,
TieredStorageNettyServiceImpl tieredStorageNettyService,
TieredStorageResourceRegistry tieredStorageResourceRegistry) |
Modifier and Type | Method and Description |
---|---|
TieredResultPartition |
createTieredResultPartition(String owningTaskName,
int partitionIndex,
ResultPartitionID partitionId,
ResultPartitionType partitionType,
int numSubpartitions,
int maxParallelism,
Boolean isBroadCastOnly,
ResultPartitionManager partitionManager,
BufferCompressor bufferCompressor,
SupplierWithException<BufferPool,IOException> bufferPoolFactory,
FileChannelManager fileChannelManager,
BatchShuffleReadBufferPool batchShuffleReadBufferPool,
ScheduledExecutorService batchShuffleReadIOExecutor,
boolean isNumberOfPartitionConsumerUndefined) |
TieredStorageConfiguration |
getTieredStorageConfiguration() |
TieredStorageNettyServiceImpl |
getTieredStorageNettyService() |
TieredStorageResourceRegistry |
getTieredStorageResourceRegistry() |
public TieredResultPartitionFactory(TieredStorageConfiguration tieredStorageConfiguration, TieredStorageNettyServiceImpl tieredStorageNettyService, TieredStorageResourceRegistry tieredStorageResourceRegistry)
public TieredStorageConfiguration getTieredStorageConfiguration()
public TieredStorageNettyServiceImpl getTieredStorageNettyService()
public TieredStorageResourceRegistry getTieredStorageResourceRegistry()
public TieredResultPartition createTieredResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int maxParallelism, Boolean isBroadCastOnly, ResultPartitionManager partitionManager, @Nullable BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory, FileChannelManager fileChannelManager, BatchShuffleReadBufferPool batchShuffleReadBufferPool, ScheduledExecutorService batchShuffleReadIOExecutor, boolean isNumberOfPartitionConsumerUndefined)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.