Uses of Class
org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage.TieredStorageResourceRegistry

Packages that use TieredStorageResourceRegistry

Package	Description
org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty
org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle
org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier
org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.disk
org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.memory
org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote

Uses of TieredStorageResourceRegistry in org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty

Constructors in org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty with parameters of type TieredStorageResourceRegistry

Constructor	Description
TieredStorageNettyServiceImpl(TieredStorageResourceRegistry resourceRegistry)

Uses of TieredStorageResourceRegistry in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle that return TieredStorageResourceRegistry

Modifier and Type	Method	Description
TieredStorageResourceRegistry	TieredResultPartitionFactory.getTieredStorageResourceRegistry()

Constructors in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle with parameters of type TieredStorageResourceRegistry

Constructor	Description
TieredResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, org.apache.flink.util.function.SupplierWithException<BufferPool,IOException> bufferPoolFactory, TieredStorageProducerClient tieredStorageProducerClient, TieredStorageResourceRegistry tieredStorageResourceRegistry, TieredStorageNettyServiceImpl nettyService, List<TieredStorageMemorySpec> tieredStorageMemorySpecs, TieredStorageMemoryManager storageMemoryManager)
TieredResultPartitionFactory(TieredStorageConfiguration tieredStorageConfiguration, TieredStorageNettyServiceImpl tieredStorageNettyService, TieredStorageResourceRegistry tieredStorageResourceRegistry)

Uses of TieredStorageResourceRegistry in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier with parameters of type TieredStorageResourceRegistry

Modifier and Type	Method	Description
TierMasterAgent	TierFactory.createMasterAgent(TieredStorageResourceRegistry tieredStorageResourceRegistry)	Creates the master-side agent of a Tier.
TierProducerAgent	TierFactory.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.

Uses of TieredStorageResourceRegistry in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.disk

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.disk with parameters of type TieredStorageResourceRegistry

Modifier and Type	Method	Description
TierMasterAgent	DiskTierFactory.createMasterAgent(TieredStorageResourceRegistry resourceRegistry)
TierProducerAgent	DiskTierFactory.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)

Uses of TieredStorageResourceRegistry in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.memory

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.memory with parameters of type TieredStorageResourceRegistry

Modifier and Type	Method	Description
TierMasterAgent	MemoryTierFactory.createMasterAgent(TieredStorageResourceRegistry tieredStorageResourceRegistry)
TierProducerAgent	MemoryTierFactory.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)

Constructors in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.memory with parameters of type TieredStorageResourceRegistry

Constructor	Description
MemoryTierProducerAgent(TieredStoragePartitionId partitionId, int numSubpartitions, int bufferSizeBytes, int segmentSizeBytes, int subpartitionMaxQueuedBuffers, boolean isBroadcastOnly, TieredStorageMemoryManager memoryManager, TieredStorageNettyService nettyService, TieredStorageResourceRegistry resourceRegistry)

Uses of TieredStorageResourceRegistry in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote with parameters of type TieredStorageResourceRegistry

Modifier and Type	Method	Description
TierMasterAgent	RemoteTierFactory.createMasterAgent(TieredStorageResourceRegistry resourceRegistry)
TierProducerAgent	RemoteTierFactory.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)