Uses of Class
org.apache.flink.runtime.io.network.partition.hybrid.tiered.common.TieredStorageSubpartitionId

Packages that use TieredStorageSubpartitionId

Package	Description
org.apache.flink.runtime.io.network.partition.hybrid.tiered.common
org.apache.flink.runtime.io.network.partition.hybrid.tiered.file
org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty
org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage
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 TieredStorageSubpartitionId in org.apache.flink.runtime.io.network.partition.hybrid.tiered.common

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.common that return TieredStorageSubpartitionId

Modifier and Type	Method	Description
static TieredStorageSubpartitionId	TieredStorageIdMappingUtils.convertId(int subpartitionId)

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

Modifier and Type	Method	Description
static int	TieredStorageIdMappingUtils.convertId(TieredStorageSubpartitionId subpartitionId)

Uses of TieredStorageSubpartitionId in org.apache.flink.runtime.io.network.partition.hybrid.tiered.file

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

Modifier and Type	Method	Description
long	PartitionFileReader.getPriority(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId, int bufferIndex, PartitionFileReader.ReadProgress readProgress)	Get the priority for reading a particular buffer from the partitioned file.
long	ProducerMergedPartitionFileReader.getPriority(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId, int bufferIndex, PartitionFileReader.ReadProgress readProgress)
long	SegmentPartitionFileReader.getPriority(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId, int bufferIndex, PartitionFileReader.ReadProgress readProgress)
PartitionFileReader.ReadBufferResult	PartitionFileReader.readBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId, int bufferIndex, org.apache.flink.core.memory.MemorySegment memorySegment, BufferRecycler recycler, PartitionFileReader.ReadProgress readProgress, CompositeBuffer partialBuffer)	Read a buffer from the partition file.
PartitionFileReader.ReadBufferResult	ProducerMergedPartitionFileReader.readBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId, int bufferIndex, org.apache.flink.core.memory.MemorySegment memorySegment, BufferRecycler recycler, PartitionFileReader.ReadProgress readProgress, CompositeBuffer partialBuffer)
PartitionFileReader.ReadBufferResult	SegmentPartitionFileReader.readBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId, int bufferIndex, org.apache.flink.core.memory.MemorySegment memorySegment, BufferRecycler recycler, PartitionFileReader.ReadProgress readProgress, CompositeBuffer partialBuffer)

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

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

Modifier and Type	Method	Description
void	NettyServiceProducer.connectionEstablished(TieredStorageSubpartitionId subpartitionId, NettyConnectionWriter nettyConnectionWriter)	NettyConnectionWriter will be created when a netty connection is established for a subpartition.
ResultSubpartitionView	TieredStorageNettyServiceImpl.createResultSubpartitionView(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, BufferAvailabilityListener availabilityListener)	Create a ResultSubpartitionView for the netty server.
CompletableFuture<NettyConnectionReader>	TieredStorageNettyService.registerConsumer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId)	TierConsumerAgent will register to TieredStorageNettyService and get a future of NettyConnectionReader.
CompletableFuture<NettyConnectionReader>	TieredStorageNettyServiceImpl.registerConsumer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId)

Uses of TieredStorageSubpartitionId in org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage that return TieredStorageSubpartitionId

Modifier and Type	Method	Description
TieredStorageSubpartitionId	TieredStorageConsumerSpec.getSubpartitionId()

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

Modifier and Type	Method	Description
void	HashBufferAccumulator.flushAccumulatedBuffers(TieredStorageSubpartitionId subpartitionId, List<Buffer> accumulatedBuffers)
void	HashSubpartitionBufferAccumulatorContext.flushAccumulatedBuffers(TieredStorageSubpartitionId subpartitionId, List<Buffer> accumulatedBuffers)	Flush the accumulated Buffers of the subpartition.
Optional<Buffer>	TieredStorageConsumerClient.getNextBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId)
void	AvailabilityNotifier.notifyAvailable(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId)	Notify that the data from the specific partition and subpartition is available in tiered storage.
void	BufferAccumulator.receive(ByteBuffer record, TieredStorageSubpartitionId subpartitionId, Buffer.DataType dataType, boolean isBroadcast)	Receives the records from tiered store producer, these records will be accumulated and transformed into finished buffers.
void	HashBufferAccumulator.receive(ByteBuffer record, TieredStorageSubpartitionId subpartitionId, Buffer.DataType dataType, boolean isBroadcast)
void	SortBufferAccumulator.receive(ByteBuffer record, TieredStorageSubpartitionId subpartitionId, Buffer.DataType dataType, boolean isBroadcast)
void	TieredStorageProducerClient.write(ByteBuffer record, TieredStorageSubpartitionId subpartitionId, Buffer.DataType dataType, boolean isBroadcast)	Write records to the producer client.

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

Modifier and Type	Method	Description
void	BufferAccumulator.setup(java.util.function.BiConsumer<TieredStorageSubpartitionId,List<Buffer>> bufferFlusher)	Setup the accumulator.
void	HashBufferAccumulator.setup(java.util.function.BiConsumer<TieredStorageSubpartitionId,List<Buffer>> accumulatedBufferFlusher)
void	SortBufferAccumulator.setup(java.util.function.BiConsumer<TieredStorageSubpartitionId,List<Buffer>> bufferFlusher)

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

Constructor	Description
HashSubpartitionBufferAccumulator(TieredStorageSubpartitionId subpartitionId, int bufferSize, HashSubpartitionBufferAccumulatorContext bufferAccumulatorContext)
TieredStorageConsumerSpec(TieredStoragePartitionId tieredStoragePartitionId, TieredStorageSubpartitionId tieredStorageSubpartitionId)

Uses of TieredStorageSubpartitionId 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 TieredStorageSubpartitionId

Modifier and Type	Method	Description
Optional<Buffer>	TierConsumerAgent.getNextBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId)	Get buffer from the consumer agent.
boolean	TierProducerAgent.tryStartNewSegment(TieredStorageSubpartitionId subpartitionId, int segmentId)	Try to start a new segment in the Tier.
boolean	TierProducerAgent.tryWrite(TieredStorageSubpartitionId subpartitionId, Buffer finishedBuffer, Object bufferOwner)	Writes the finished Buffer to the consumer.

Uses of TieredStorageSubpartitionId 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 TieredStorageSubpartitionId

Modifier and Type	Method	Description
void	DiskIOScheduler.connectionEstablished(TieredStorageSubpartitionId subpartitionId, NettyConnectionWriter nettyConnectionWriter)
void	DiskTierProducerAgent.connectionEstablished(TieredStorageSubpartitionId subpartitionId, NettyConnectionWriter nettyConnectionWriter)
Optional<Buffer>	DiskTierConsumerAgent.getNextBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId)
boolean	DiskTierProducerAgent.tryStartNewSegment(TieredStorageSubpartitionId subpartitionId, int segmentId)
boolean	DiskTierProducerAgent.tryWrite(TieredStorageSubpartitionId subpartitionId, Buffer finishedBuffer, Object bufferOwner)

Uses of TieredStorageSubpartitionId 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 TieredStorageSubpartitionId

Modifier and Type	Method	Description
void	MemoryTierProducerAgent.connectionEstablished(TieredStorageSubpartitionId subpartitionId, NettyConnectionWriter nettyConnectionWriter)
Optional<Buffer>	MemoryTierConsumerAgent.getNextBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId)
boolean	MemoryTierProducerAgent.tryStartNewSegment(TieredStorageSubpartitionId subpartitionId, int segmentId)
boolean	MemoryTierProducerAgent.tryWrite(TieredStorageSubpartitionId subpartitionId, Buffer finishedBuffer, Object bufferOwner)

Uses of TieredStorageSubpartitionId 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 TieredStorageSubpartitionId

Modifier and Type	Method	Description
Optional<Buffer>	RemoteTierConsumerAgent.getNextBuffer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId)
boolean	RemoteTierProducerAgent.tryStartNewSegment(TieredStorageSubpartitionId subpartitionId, int segmentId)
boolean	RemoteTierProducerAgent.tryWrite(TieredStorageSubpartitionId subpartitionId, Buffer buffer, Object bufferOwner)
void	RemoteStorageScanner.watchSegment(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, int segmentId)	Watch the segment for a specific subpartition in the RemoteStorageScanner.