BlockFetchStarter

= BlockFetchStarter

BlockFetchStarter is the <> of...FIXME...to <>.

[[contract]] [[createAndStart]] [source, java]


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


createAndStart is used when:

  • ExternalShuffleClient is requested to storage:ExternalShuffleClient.md#fetchBlocks[fetchBlocks] (when network:TransportConf.md#io.maxRetries[maxIORetries] is 0)

  • NettyBlockTransferService is requested to storage:NettyBlockTransferService.md#fetchBlocks[fetchBlocks] (when network:TransportConf.md#io.maxRetries[maxIORetries] is 0)

  • RetryingBlockFetcher is requested to core:RetryingBlockFetcher.md#fetchAllOutstanding[fetchAllOutstanding]


Last update: 2020-10-06