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

Interface TierFactory

All Known Implementing Classes:

DiskTierFactory, MemoryTierFactory, RemoteTierFactory

public interface TierFactory

A factory that creates all the components of a tier.

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 storageMemoryManager, TieredStorageNettyService nettyService, TieredStorageResourceRegistry resourceRegistry, BatchShuffleReadBufferPool bufferPool, ScheduledExecutorService ioExecutor, int maxRequestedBuffers, java.time.Duration bufferRequestTimeout)	Creates the producer-side agent of a Tier.

Method Detail

createMasterAgent

TierMasterAgent createMasterAgent(TieredStorageResourceRegistry tieredStorageResourceRegistry)

Creates the master-side agent of a Tier.

createProducerAgent

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

Creates the producer-side agent of a Tier.

createConsumerAgent

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

Creates the consumer-side agent of a Tier.