RpcResponseCallback

= RpcResponseCallback

RpcResponseCallback is the <> of...FIXME

[[contract]] [source, java]


package org.apache.spark.network.client;

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


.RpcResponseCallback Contract [cols="1,2",options="header",width="100%"] |=== | Method | Description

| onSuccess a| [[onSuccess]] Used when:

  • NettyBlockRpcServer is requested to storage:NettyBlockRpcServer.md#receive[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 | [[onFailure]] Used when...FIXME |===

[[implementations]] .RpcResponseCallbacks [cols="1,2",options="header",width="100%"] |=== | RpcResponseCallback | Description

"Unnamed" in NettyBlockTransferService
"Unnamed" in TransportRequestHandler
"Unnamed" in TransportClient
"Unnamed" in storage:OneForOneBlockFetcher.md[]

| OneWayRpcCallback | [[OneWayRpcCallback]]

| RegisterDriverCallback | [[RegisterDriverCallback]]

| RpcOutboxMessage | [[RpcOutboxMessage]] |===


Last update: 2020-10-06