BlockFetchStarter
= BlockFetchStarter
BlockFetchStarter is the <
[[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] is0
) -
NettyBlockTransferService
is requested to storage:NettyBlockTransferService.md#fetchBlocks[fetchBlocks] (when network:TransportConf.md#io.maxRetries[maxIORetries] is0
) -
RetryingBlockFetcher
is requested to core:RetryingBlockFetcher.md#fetchAllOutstanding[fetchAllOutstanding]
Last update: 2020-10-06