spark-RpcResponseCallback.adoc

RpcResponseCallback

RpcResponseCallback is the contract of…​FIXME

package org.apache.spark.network.client;

interface RpcResponseCallback {
  void onSuccess(ByteBuffer response);
  void onFailure(Throwable e);
}

Table 1. RpcResponseCallback Contract

Method	Description
onSuccess	Used when: NettyBlockRpcServer is requested to receive RPC messages (i.e. OpenBlocks and UploadBlock messages) RemoteNettyRpcCallContext is requested to send TransportResponseHandler is requested to handle a RpcResponse message ExternalShuffleBlockHandler is requested to handleMessage (i.e. OpenBlocks and RegisterExecutor messages) AuthRpcHandler and SaslRpcHandler are requested to receive Spark on Mesos' MesosExternalShuffleBlockHandler is requested to handleMessage (i.e. RegisterDriverParam message)
onFailure	Used when…​FIXME

Table 2. RpcResponseCallbacks

RpcResponseCallback	Description
"Unnamed" in NettyBlockTransferService
"Unnamed" in TransportRequestHandler
"Unnamed" in TransportClient
"Unnamed" in OneForOneBlockFetcher
OneWayRpcCallback
RegisterDriverCallback
RpcOutboxMessage