Skip to content

TransportRequestHandler

= TransportRequestHandler

TransportRequestHandler is a network:MessageHandler.md[] of <> from Netty's <>.

== [[creating-instance]] Creating Instance

TransportRequestHandler takes the following to be created:

TransportRequestHandler is created when TransportContext is requested to network:TransportContext.md#createChannelHandler[create a ChannelHandler].

== [[processRpcRequest]] processRpcRequest Internal Method

[source, java]

void processRpcRequest( RpcRequest req)


processRpcRequest...FIXME

processRpcRequest is used when TransportRequestHandler is requested to <>.

== [[processFetchRequest]] processFetchRequest Internal Method

[source, java]

void processFetchRequest( ChunkFetchRequest req)


processFetchRequest...FIXME

processFetchRequest is used when TransportRequestHandler is requested to <>.

== [[processOneWayMessage]] processOneWayMessage Internal Method

[source, java]

void processOneWayMessage(OneWayMessage req)

processOneWayMessage...FIXME

NOTE: processOneWayMessage is used exclusively when TransportRequestHandler is requested to <> a OneWayMessage request.

== [[processStreamRequest]] processStreamRequest Internal Method

[source, java]

void processStreamRequest(final StreamRequest req)

processStreamRequest...FIXME

NOTE: processStreamRequest is used exclusively when TransportRequestHandler is requested to <> a StreamRequest request.

== [[handle]] Handling RequestMessages -- handle Method

[source, java]

void handle(RequestMessage request)

handle branches off per the type of the input RequestMessage:

  • For ChunkFetchRequest requests, handle <>

  • For RpcRequest requests, handle <>

  • For OneWayMessage requests, handle <>

  • For StreamRequest requests, handle <>

For unknown requests, handle simply throws a IllegalArgumentException.

Unknown request type: [request]

handle is part of network:MessageHandler.md#handle[MessageHandler] abstraction.

== [[logging]] Logging

Enable ALL logging level for org.apache.spark.network.server.TransportRequestHandler logger to see what happens inside.

Add the following line to conf/log4j.properties:

[source,plaintext]

log4j.logger.org.apache.spark.network.server.TransportRequestHandler=ALL

Refer to ROOT:spark-logging.md[Logging].


Last update: 2020-10-06