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