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, TieredStorageSubpartitionId tieredStorageSubpartitionId)

Method Summary

Modifier and Type	Method	Description
TieredStoragePartitionId	getPartitionId()
TieredStorageSubpartitionId	getSubpartitionId()

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,
                                 TieredStorageSubpartitionId tieredStorageSubpartitionId)

Method Detail

getPartitionId

public TieredStoragePartitionId getPartitionId()

getSubpartitionId

public TieredStorageSubpartitionId getSubpartitionId()