ExternalShuffleClient is a ShuffleClient that…FIXME
void registerWithShuffleServer(
String host,
int port,
String execId,
ExecutorShuffleInfo executorInfo) throws IOException, InterruptedExceptionregisterWithShuffleServer…FIXME
|
Note
|
registerWithShuffleServer is used when…FIXME
|
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