org.apache.spark.rpc

Interface RpcCallContext

public interface RpcCallContext

A callback that RpcEndpoint can use to send back a message or failure. It's thread-safe and can be called in any thread.

Method Summary

Modifier and Type	Method and Description
void	reply(Object response) Reply a message to the sender.
org.apache.spark.rpc.RpcAddress	senderAddress() The sender of this message.
void	sendFailure(Throwable e) Report a failure to the sender.

Method Detail

reply

void reply(Object response)

Reply a message to the sender. If the sender is RpcEndpoint, its RpcEndpoint.receive will be called.

Parameters:

response - (undocumented)

sendFailure

void sendFailure(Throwable e)

Report a failure to the sender.

Parameters:

e - (undocumented)

senderAddress

org.apache.spark.rpc.RpcAddress senderAddress()

The sender of this message.

Returns:

(undocumented)