Skip to content


BlockStoreClient is an abstraction of block clients that can fetch blocks from a remote node (an executor or an external service).

BlockStoreClient is a Java Closeable.


Fetching Blocks

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

Fetches blocks from a remote node (using DownloadFileManager)

Used when:

Shuffle Metrics

MetricSet shuffleMetrics()

Shuffle MetricsSet

Default: (empty)

Used when:


Last update: 2021-07-24
Back to top