Interface | Description |
---|---|
FencedMessage<F extends Serializable,P> |
Interface for fenced messages.
|
Message |
Marker interface for all Flink RPC related messages.
|
RpcInvocation |
Interface for rpc invocation messages.
|
Class | Description |
---|---|
CallAsync |
Message for asynchronous callable invocations.
|
LocalFencedMessage<F extends Serializable,P> |
Local
FencedMessage implementation. |
LocalRpcInvocation |
Local rpc invocation message containing the remote procedure name, its parameter types and the
corresponding call arguments.
|
RemoteFencedMessage<F extends Serializable,P extends Serializable> |
Remote
FencedMessage implementation. |
RemoteHandshakeMessage |
Handshake message between rpc endpoints.
|
RemoteRpcInvocation |
Remote rpc invocation message which is used when the actor communication is remote.
|
RunAsync |
Message for asynchronous runnable invocations.
|
Enum | Description |
---|---|
HandshakeSuccessMessage |
Handshake success response.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.