OneForOneBlockFetcher¶
Creating Instance¶
OneForOneBlockFetcher
takes the following to be created:
-
TransportClient
- Application ID
- Executor ID
- Block IDs
- BlockFetchingListener
- TransportConf
-
DownloadFileManager
OneForOneBlockFetcher
is created when:
NettyBlockTransferService
is requested to fetch blocksExternalBlockStoreClient
is requested to fetch blocks
createFetchShuffleBlocksMsg¶
FetchShuffleBlocks createFetchShuffleBlocksMsg(
String appId,
String execId,
String[] blockIds)
createFetchShuffleBlocksMsg
...FIXME
Last update: 2020-12-19