Skip to content

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:

shuffleMetrics

MetricSet shuffleMetrics()

Shuffle MetricsSet

Default: (empty)

Used when:

Implementations


Last update: 2020-12-16