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.
-
fetchBlocks
fetches a sequence of blocks from a remote node asynchronously.public abstract void fetchBlocks( String host, int port, String execId, String[] blockIds, BlockFetchingListener listener);