spark-BlockFetchingListener.adoc

BlockFetchingListener

BlockFetchingListener is the contract of EventListeners that want to be notified about onBlockFetchSuccess and onBlockFetchFailure.

BlockFetchingListener is used when:

• ShuffleClient, BlockTransferService, NettyBlockTransferService, and ExternalShuffleClient are requested to fetch a sequence of blocks

• BlockFetchStarter is requested to createAndStart

• RetryingBlockFetcher and OneForOneBlockFetcher are created

package org.apache.spark.network.shuffle;

interface BlockFetchingListener extends EventListener {
  void onBlockFetchSuccess(String blockId, ManagedBuffer data);
  void onBlockFetchFailure(String blockId, Throwable exception);
}

Table 1. BlockFetchingListener Contract

Method	Description
onBlockFetchSuccess	Used when…​FIXME
onBlockFetchFailure	Used when…​FIXME

Table 2. BlockFetchingListeners

BlockFetchingListener	Description
RetryingBlockFetchListener
"Unnamed" in ShuffleBlockFetcherIterator
"Unnamed" in BlockTransferService