RpcResponseCallback-spark技术分享

RpcResponseCallback

RpcResponseCallback is the contract of…FIXME



package org.apache.spark.network.client;

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

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`