Uses of Class
org.apache.flink.runtime.io.network.partition.hybrid.tiered.common.TieredStorageInputChannelId
-
-
Uses of TieredStorageInputChannelId 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 TieredStorageInputChannelId Modifier and Type Method Description TieredStorageInputChannelIdTieredStorageConsumerSpec. getInputChannelId()Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage with parameters of type TieredStorageInputChannelId Modifier and Type Method Description voidAvailabilityNotifier. notifyAvailable(TieredStoragePartitionId partitionId, TieredStorageInputChannelId inputChannelId)Notify that the data for the specific partition and input channel is available in tiered storage.Constructors in org.apache.flink.runtime.io.network.partition.hybrid.tiered.storage with parameters of type TieredStorageInputChannelId Constructor Description TieredStorageConsumerSpec(TieredStoragePartitionId tieredStoragePartitionId, TieredStorageInputChannelId tieredStorageInputChannelId, ResultSubpartitionIndexSet tieredStorageSubpartitionIds) -
Uses of TieredStorageInputChannelId 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 TieredStorageInputChannelId Modifier and Type Method Description voidRemoteTierConsumerAgent. notifyAvailable(TieredStoragePartitionId partitionId, TieredStorageInputChannelId inputChannelId)
-