Skip to content

spark-TransportClientFactory.adoc

Latest commit

 

History

History
42 lines (28 loc) · 1.27 KB

spark-TransportClientFactory.adoc

File metadata and controls

42 lines (28 loc) · 1.27 KB

TransportClientFactory

TransportClientFactory is…​FIXME

createUnmanagedClient Method

TransportClient createUnmanagedClient(String remoteHost, int remotePort)
  throws IOException, InterruptedException

createUnmanagedClient…​FIXME

Note
 createUnmanagedClient is used when…​FIXME

createClient Internal Method

TransportClient createClient(String remoteHost, int remotePort)
  throws IOException, InterruptedException
TransportClient createClient(InetSocketAddress address)
  throws IOException, InterruptedException

createClient…​FIXME

Note

createClient is used when:

  • NettyBlockTransferService is requested to fetchBlocks and uploadBlock

  • NettyRpcEnv is requested to createClient and downloadClient

  • TransportClientFactory is requested to createUnmanagedClient.

  • ExternalShuffleClient is requested to fetchBlocks

  • Spark on Mesos' MesosExternalShuffleClient is requested to registerDriverWithShuffleService