Package org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote
-
Class Summary Class Description RemoteStorageScanner TheRemoteStorageScanner
is introduced to notify asynchronously for file reading on remote storage.RemoteTierConsumerAgent The data client is used to fetch data from remote tier.RemoteTierFactory The implementation ofTierFactory
for remote tier.RemoteTierMasterAgent The implementation ofTierMasterAgent
for the remote tier.RemoteTierProducerAgent The implementation ofTierProducerAgent
for the remote tier.RemoteTierShuffleDescriptor The shuffle descriptor implementation for remote tier.