BlockFetchingListener¶

BlockFetchingListener is an extension of the EventListener (Java) abstraction that want to be notified about block fetch success and failures.

BlockFetchingListener is used to create a OneForOneBlockFetcher, OneForOneBlockPusher and RetryingBlockFetcher.

Contract¶

onBlockFetchFailure¶

void onBlockFetchFailure(
  String blockId,
  Throwable exception)

onBlockFetchSuccess¶

void onBlockFetchSuccess(
  String blockId,
  ManagedBuffer data)

Implementations¶

• "Unnamed" in ShuffleBlockFetcherIterator
• "Unnamed" in BlockTransferService
• RetryingBlockFetchListener