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:
-
NettyBlockRpcServeris requested to storage:NettyBlockRpcServer.md#receive[receive RPC messages] (i.e.OpenBlocksandUploadBlockmessages) -
RemoteNettyRpcCallContextis requested tosend -
TransportResponseHandleris requested to handle aRpcResponsemessage -
AuthRpcHandlerandSaslRpcHandlerare 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]] |===