org.apache.flink.runtime.rpc.messages

Interface RpcInvocation

All Known Implementing Classes:

LocalRpcInvocation, RemoteRpcInvocation

public interface RpcInvocation

Interface for rpc invocation messages. The interface allows to request all necessary information to lookup a method and call it with the corresponding arguments.

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

Method Detail

getMethodName

String getMethodName()
              throws IOException,
                     ClassNotFoundException

Returns the method's name.

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

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

Returns the method's parameter types

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

Object[] getArgs()
          throws IOException,
                 ClassNotFoundException

Returns the arguments of the remote procedure call

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