public void init(String appId)ShuffleClient
ShuffleClient is an interface (abstract class) for reading shuffle files.
|
Note
|
BlockTransferService, ExternalShuffleClient, MesosExternalShuffleClient are the current implementations of ShuffleClient Contract. |
ShuffleClient Contract
Every ShuffleClient can do the following:
-
It can be
init. The default implementation does nothing by default.
-
fetchBlocksfetches a sequence of blocks from a remote node asynchronously.public abstract void fetchBlocks( String host, int port, String execId, String[] blockIds, BlockFetchingListener listener);