Skip to content

NettyRpcEnv

NettyRpcEnv is an RpcEnv using Netty ("an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers & clients").

Creating Instance

NettyRpcEnv takes the following to be created:

  • [[conf]] ROOT:SparkConf.md[]
  • [[javaSerializerInstance]] JavaSerializerInstance
  • [[host]] Host name
  • [[securityManager]] SecurityManager
  • [[numUsableCores]] Number of CPU cores

NettyRpcEnv is created when NettyRpcEnvFactory is requested to create an RpcEnv.

== [[streamManager]] NettyStreamManager

NettyRpcEnv creates a NettyStreamManager.md[] when <>.

NettyStreamManager is used for the following:

  • Create a NettyRpcHandler for the <>

  • As the RpcEnv.md#fileServer[RpcEnvFileServer]

== [[transportContext]] TransportContext

NettyRpcEnv creates a network:TransportContext.md[].

== [[startServer]] Starting Server

[source,scala]

startServer( bindAddress: String, port: Int): Unit


startServer...FIXME

startServer is used when NettyRpcEnvFactory is requested to rpc:NettyRpcEnvFactory.md#create[create an RpcEnv] (in server mode).

== [[deserialize]] deserialize Method

[source,scala]

deserializeT: ClassTag: T


deserialize...FIXME

deserialize is used when:

  • RequestMessage utility is created

  • NettyRpcEnv is requested to <>


Last update: 2020-10-14