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

Interface AvailabilityNotifier

All Known Implementing Classes:

RemoteTierConsumerAgent

public interface AvailabilityNotifier

AvailabilityNotifier is used to notify that the data from the specific partition and subpartition in tiered storage is available.

Method Summary

Modifier and Type	Method	Description
void	notifyAvailable(TieredStoragePartitionId partitionId, TieredStorageInputChannelId inputChannelId)	Notify that the data for the specific partition and input channel is available in tiered storage.
void	notifyAvailable(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId)	Notify that the data from the specific partition and subpartition is available in tiered storage.

Method Detail

notifyAvailable

void notifyAvailable(TieredStoragePartitionId partitionId,
                     TieredStorageSubpartitionId subpartitionId)

Notify that the data from the specific partition and subpartition is available in tiered storage.

Parameters:

partitionId - the partition id.

subpartitionId - the subpartition id.

notifyAvailable

void notifyAvailable(TieredStoragePartitionId partitionId,
                     TieredStorageInputChannelId inputChannelId)

Notify that the data for the specific partition and input channel is available in tiered storage.

Parameters:

partitionId - the partition id.

inputChannelId - the input channel id.