BlockStoreClient¶

BlockStoreClient is an abstraction of block clients that can fetch blocks from a remote node.

BlockStoreClient is a Java Closeable.

Contract¶

fetchBlocks¶

void fetchBlocks(
  String host,
  int port,
  String execId,
  String[] blockIds,
  BlockFetchingListener listener,
  DownloadFileManager downloadFileManager)

Fetches blocks from a remote node

Used when:

• BlockTransferService is requested to fetchBlockSync
• ShuffleBlockFetcherIterator is requested to sendRequest

shuffleMetrics¶

MetricSet shuffleMetrics()

Shuffle MetricsSet

Default: (empty)

Used when:

• BlockManager is requested for a Shuffle Metrics Source

Implementations¶

• BlockTransferService
• ExternalBlockStoreClient