org.apache.flink.runtime.rpc.messages

Class RemoteRpcInvocation

java.lang.Object

org.apache.flink.runtime.rpc.messages.RemoteRpcInvocation

All Implemented Interfaces:

Serializable, Message, RpcInvocation

public class RemoteRpcInvocation
extends Object
implements RpcInvocation, Serializable

Remote rpc invocation message which is used when the actor communication is remote and, thus, the message has to be serialized.

In order to fail fast and report an appropriate error message to the user, the method name, the parameter types and the arguments are eagerly serialized. In case the invocation call contains a non-serializable object, then an IOException is thrown.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RemoteRpcInvocation(String declaringClassName, String methodName, Class<?>[] parameterTypes, Object[] args)

Method Summary

Modifier and Type	Method and Description
Object[]	getArgs() Returns the arguments of the remote procedure call.
String	getMethodName() Returns the method's name.
Class<?>[]	getParameterTypes() Returns the method's parameter types.
long	getSize() Size (#bytes of the serialized data) of the rpc invocation message.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.rpc.messages.RpcInvocation

convertRpcToString

Constructor Detail

RemoteRpcInvocation

public RemoteRpcInvocation(String declaringClassName,
                           String methodName,
                           Class<?>[] parameterTypes,
                           Object[] args)
                    throws IOException

Throws:

IOException

Method Detail

getMethodName

public String getMethodName()
                     throws IOException,
                            ClassNotFoundException

Description copied from interface: RpcInvocation

Returns the method's name.

Specified by:

getMethodName in interface RpcInvocation

Returns:

Method name

Throws:

IOException - if the rpc invocation message is a remote message and could not be deserialized

ClassNotFoundException - if the rpc invocation message is a remote message and contains serialized classes which cannot be found on the receiving side

getParameterTypes

public Class<?>[] getParameterTypes()
                             throws IOException,
                                    ClassNotFoundException

Description copied from interface: RpcInvocation

Returns the method's parameter types.

Specified by:

getParameterTypes in interface RpcInvocation

Returns:

Method's parameter types

Throws:

IOException - if the rpc invocation message is a remote message and could not be deserialized

ClassNotFoundException - if the rpc invocation message is a remote message and contains serialized classes which cannot be found on the receiving side

getArgs

public Object[] getArgs()
                 throws IOException,
                        ClassNotFoundException

Description copied from interface: RpcInvocation

Returns the arguments of the remote procedure call.

Specified by:

getArgs in interface RpcInvocation

Returns:

Arguments of the remote procedure call

Throws:

IOException - if the rpc invocation message is a remote message and could not be deserialized

ClassNotFoundException - if the rpc invocation message is a remote message and contains serialized classes which cannot be found on the receiving side

toString

public String toString()

Overrides:

toString in class Object

getSize

public long getSize()

Size (#bytes of the serialized data) of the rpc invocation message.

Returns:

Size of the remote rpc invocation message