BlockFetchingListener

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

BlockFetchingListener is used when:

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

results matching ""

    No results matching ""