Skip to content

OneForOneBlockFetcher

Creating Instance

OneForOneBlockFetcher takes the following to be created:

OneForOneBlockFetcher is created when:

createFetchShuffleBlocksMsg

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

createFetchShuffleBlocksMsg...FIXME

Starting

void start()

start requests the TransportClient to sendRpc the BlockTransferMessage

start...FIXME

start is used when:

Logging

Enable ALL logging level for org.apache.spark.network.shuffle.OneForOneBlockFetcher logger to see what happens inside.

Add the following line to conf/log4j.properties:

log4j.logger.org.apache.spark.network.shuffle.OneForOneBlockFetcher=ALL

Refer to Logging.

Back to top