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.

results matching ""

    No results matching ""