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 blocks
• ExternalBlockStoreClient is requested to fetch blocks

createFetchShuffleBlocksMsg¶

FetchShuffleBlocks createFetchShuffleBlocksMsg(
  String appId,
  String execId,
  String[] blockIds)

createFetchShuffleBlocksMsg...FIXME