spark-RetryingBlockFetcher-BlockFetchStarter.adoc

BlockFetchStarter

BlockFetchStarter is the contract of…​FIXME…​to createAndStart.

void createAndStart(String[] blockIds, BlockFetchingListener listener)
   throws IOException, InterruptedException;

createAndStart is used when:

• ExternalShuffleClient is requested to fetchBlocks (when maxIORetries is 0)

• NettyBlockTransferService is requested to fetchBlocks (when maxIORetries is 0)

• RetryingBlockFetcher is requested to fetchAllOutstanding