BlockFetchStarter

2014-02-08 分类：spark-core 阅读(981) 评论(0)

BlockFetchStarter is the contract of…FIXME…to createAndStart.



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

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

赞(0) 打赏

关注公众号：spark技术分享