RpcResponseCallback
= RpcResponseCallback
RpcResponseCallback is the <
[[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
andUploadBlock
messages) -
RemoteNettyRpcCallContext
is requested tosend
-
TransportResponseHandler
is requested to handle aRpcResponse
message -
AuthRpcHandler
andSaslRpcHandler
are requested toreceive
| 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]] |===