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

results matching ""

    No results matching ""