Package org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.memory

Class MemoryTierFactory

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.memory.MemoryTierFactory

All Implemented Interfaces:

TierFactory

public class MemoryTierFactory
extends Object
implements TierFactory

The implementation of TierFactory for memory tier.

Constructor Summary

Constructors

Constructor	Description
MemoryTierFactory(int segmentSizeBytes, int bufferSizeBytes, int subpartitionMaxQueuedBuffers)

Method Summary

Modifier and Type	Method	Description
TierConsumerAgent	createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)	Creates the consumer-side agent of a Tier.
TierMasterAgent	createMasterAgent(TieredStorageResourceRegistry tieredStorageResourceRegistry)	Creates the master-side agent of a Tier.
TierProducerAgent	createProducerAgent(int numSubpartitions, TieredStoragePartitionId partitionID, String dataFileBasePath, boolean isBroadcastOnly, TieredStorageMemoryManager memoryManager, TieredStorageNettyService nettyService, TieredStorageResourceRegistry resourceRegistry, BatchShuffleReadBufferPool bufferPool, ScheduledExecutorService ioExecutor, int maxRequestedBuffers, java.time.Duration bufferRequestTimeout, int maxBufferReadAhead)	Creates the producer-side agent of a Tier.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MemoryTierFactory

public MemoryTierFactory(int segmentSizeBytes,
                         int bufferSizeBytes,
                         int subpartitionMaxQueuedBuffers)

Method Detail

createMasterAgent

public TierMasterAgent createMasterAgent(TieredStorageResourceRegistry tieredStorageResourceRegistry)

Description copied from interface: TierFactory

Creates the master-side agent of a Tier.

Specified by:

createMasterAgent in interface TierFactory

createProducerAgent

public TierProducerAgent createProducerAgent(int numSubpartitions,
                                             TieredStoragePartitionId partitionID,
                                             String dataFileBasePath,
                                             boolean isBroadcastOnly,
                                             TieredStorageMemoryManager memoryManager,
                                             TieredStorageNettyService nettyService,
                                             TieredStorageResourceRegistry resourceRegistry,
                                             BatchShuffleReadBufferPool bufferPool,
                                             ScheduledExecutorService ioExecutor,
                                             int maxRequestedBuffers,
                                             java.time.Duration bufferRequestTimeout,
                                             int maxBufferReadAhead)

Description copied from interface: TierFactory

Creates the producer-side agent of a Tier.

Specified by:

createProducerAgent in interface TierFactory

createConsumerAgent

public TierConsumerAgent createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs,
                                             TieredStorageNettyService nettyService)

Description copied from interface: TierFactory

Creates the consumer-side agent of a Tier.

Specified by:

createConsumerAgent in interface TierFactory