spark技术分享RpcHandler
RpcHandler uses a OneWayRpcCallback that…FIXME
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
package org.apache.spark.network.server; abstract class RpcHandler { // only required methods that have no implementation // the others follow abstract void receive( TransportClient client, ByteBuffer message, RpcResponseCallback callback); abstract StreamManager getStreamManager(); } |
| Method | Description |
|---|---|
|
|
|
|
|
Used when…FIXME |
| RpcHandler | Description |
|---|---|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
OneWayRpcCallback RpcResponseCallback
OneWayRpcCallback is a RpcResponseCallback that simply prints out the WARN and ERROR for the following methods onSuccess and onFailure respectively.
|
1 2 3 4 5 6 |
void onSuccess(ByteBuffer response) Response provided for one-way RPC. |
|
1 2 3 4 5 6 |
void onFailure(Throwable e) Error response provided for one-way RPC. |
