ExternalShuffleClient

ExternalShuffleClient is a ShuffleClient that…​FIXME

Register Block Manager with Shuffle Server — registerWithShuffleServer Method

void registerWithShuffleServer(
  String host,
  int port,
  String execId,
  ExecutorShuffleInfo executorInfo) throws IOException, InterruptedException

registerWithShuffleServer…​FIXME

Note
registerWithShuffleServer is used when…​FIXME

fetchBlocks Method

void fetchBlocks(
  String host,
  int port,
  String execId,
  String[] blockIds,
  BlockFetchingListener listener,
  TempFileManager tempFileManager)
Note
fetchBlocks is part of ShuffleClient Contract to…​FIXME.

fetchBlocks…​FIXME

results matching ""

    No results matching ""