TransportContext
= TransportContext
TransportContext is used to create a <
== [[creating-instance]] Creating Instance
TransportContext takes the following to be created:
- [[conf]] network:TransportConf.md[]
- [[rpcHandler]] network:RpcHandler.md[]
- [[closeIdleConnections]] closeIdleConnections flag (default:
false
)
TransportContext is created when:
-
ExternalShuffleClient is requested to storage:ExternalShuffleClient.md#init[initialize]
-
YarnShuffleService is requested to spark-on-yarn:spark-yarn-YarnShuffleService.md#serviceInit[serviceInit]
== [[createClientFactory]] createClientFactory Method
[source,java]¶
TransportClientFactory createClientFactory( List
createClientFactory...FIXME
createClientFactory is used when TransportContext is requested to <
== [[createChannelHandler]] createChannelHandler Method
[source, java]¶
TransportChannelHandler createChannelHandler( Channel channel, RpcHandler rpcHandler)
createChannelHandler...FIXME
createChannelHandler is used when TransportContext is requested to <
== [[initializePipeline]] initializePipeline Method
[source, java]¶
TransportChannelHandler initializePipeline( SocketChannel channel) // <1> TransportChannelHandler initializePipeline( SocketChannel channel, RpcHandler channelRpcHandler)
<1> Uses the <
initializePipeline...FIXME
initializePipeline is used when:
-
TransportServer
is requested to network:TransportServer.md#init[init] -
TransportClientFactory
is requested to network:TransportClientFactory.md#createClient[createClient]
== [[createServer]] Creating Server
[source, java]¶
TransportServer createServer() TransportServer createServer( int port, List
createServer simply creates a TransportServer (with the current TransportContext, the host, the port, the <
createServer is used when:
-
NettyBlockTransferService
is requested to storage:NettyBlockTransferService.md#createServer[createServer] -
NettyRpcEnv
is requested tostartServer
-
ExternalShuffleService
is requested to start -
Spark on YARN's
YarnShuffleService
is requested toserviceInit