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

Class TieredStorageConsumerSpec

java.lang.Object

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

public class TieredStorageConsumerSpec
extends Object

Describe the different data sources in TieredStorageConsumerClient.

Constructor Summary

Constructors

Constructor	Description
TieredStorageConsumerSpec(TieredStoragePartitionId tieredStoragePartitionId, TieredStorageInputChannelId tieredStorageInputChannelId, ResultSubpartitionIndexSet tieredStorageSubpartitionIds)

Method Summary

Modifier and Type	Method	Description
TieredStorageInputChannelId	getInputChannelId()
TieredStoragePartitionId	getPartitionId()
ResultSubpartitionIndexSet	getSubpartitionIds()

Methods inherited from class java.lang.Object

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

Constructor Detail

TieredStorageConsumerSpec

public TieredStorageConsumerSpec(TieredStoragePartitionId tieredStoragePartitionId,
                                 TieredStorageInputChannelId tieredStorageInputChannelId,
                                 ResultSubpartitionIndexSet tieredStorageSubpartitionIds)

Method Detail

getPartitionId

public TieredStoragePartitionId getPartitionId()

getInputChannelId

public TieredStorageInputChannelId getInputChannelId()

getSubpartitionIds

public ResultSubpartitionIndexSet getSubpartitionIds()