spark-RpcHandler.adoc

RpcHandler

RpcHandler is the base of…​FIXME

RpcHandler uses a OneWayRpcCallback that…​FIXME

package org.apache.spark.network.server;

abstract class RpcHandler {
  // only required methods that have no implementation
  // the others follow
  abstract void receive(
    TransportClient client,
    ByteBuffer message,
    RpcResponseCallback callback);
  abstract StreamManager getStreamManager();
}

Table 1. (Subset of) RpcHandler Contract

Method	Description
receive	Used when: AuthRpcHandler is requested to receive SaslRpcHandler is requested to receive (after authentication is complete) TransportRequestHandler is requested to processRpcRequest
getStreamManager	Used when…​FIXME

Table 2. RpcHandlers

RpcHandler	Description
AuthRpcHandler
ExternalShuffleBlockHandler
NettyBlockRpcServer
NettyRpcHandler
NoOpRpcHandler
SaslRpcHandler

OneWayRpcCallback RpcResponseCallback

OneWayRpcCallback is a RpcResponseCallback that simply prints out the WARN and ERROR for the following methods onSuccess and onFailure respectively.

void onSuccess(ByteBuffer response)

Response provided for one-way RPC.

void onFailure(Throwable e)

Error response provided for one-way RPC.