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

Packages that use TieredStorageConsumerSpec

Package	Description
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty
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 TieredStorageConsumerSpec in org.apache.flink.runtime.io.network.partition.consumer

Constructor parameters in org.apache.flink.runtime.io.network.partition.consumer with type arguments of type TieredStorageConsumerSpec

Constructor

Description

SingleInputGate(String owningTaskName, int gateIndex, IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, IndexRange subpartitionIndexRange, int numberOfInputChannels, PartitionProducerStateProvider partitionProducerStateProvider, org.apache.flink.util.function.SupplierWithException<BufferPool,IOException> bufferPoolFactory, BufferDecompressor bufferDecompressor, org.apache.flink.core.memory.MemorySegmentProvider memorySegmentProvider, int segmentSize, ThroughputCalculator throughputCalculator, BufferDebloater bufferDebloater, TieredStorageConsumerClient tieredStorageConsumerClient, TieredStorageNettyServiceImpl nettyService, List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs)

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

Method parameters in org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty with type arguments of type TieredStorageConsumerSpec

Modifier and Type	Method	Description
void	TieredStorageNettyServiceImpl.setupInputChannels(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, List<java.util.function.Supplier<InputChannel>> inputChannelProviders)	Set up input channels in SingleInputGate.

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

Method parameters in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier with type arguments of type TieredStorageConsumerSpec

Modifier and Type	Method	Description
TierConsumerAgent	TierFactory.createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)	Creates the consumer-side agent of a Tier.

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

Method parameters in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.disk with type arguments of type TieredStorageConsumerSpec

Modifier and Type	Method	Description
TierConsumerAgent	DiskTierFactory.createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)

Constructor parameters in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.disk with type arguments of type TieredStorageConsumerSpec

Constructor	Description
DiskTierConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)

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

Method parameters in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.memory with type arguments of type TieredStorageConsumerSpec

Modifier and Type	Method	Description
TierConsumerAgent	MemoryTierFactory.createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)

Constructor parameters in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.memory with type arguments of type TieredStorageConsumerSpec

Constructor	Description
MemoryTierConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)

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

Method parameters in org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote with type arguments of type TieredStorageConsumerSpec

Modifier and Type	Method	Description
TierConsumerAgent	RemoteTierFactory.createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)