Package | Description |
---|---|
org.apache.flink.runtime.rpc.messages |
Modifier and Type | Interface and Description |
---|---|
interface |
FencedMessage<F extends Serializable,P>
Interface for fenced messages.
|
interface |
RpcInvocation
Interface for rpc invocation messages.
|
Modifier and Type | Class and Description |
---|---|
class |
CallAsync
Message for asynchronous callable invocations.
|
class |
HandshakeSuccessMessage
Handshake success response.
|
class |
LocalFencedMessage<F extends Serializable,P>
Local
FencedMessage implementation. |
class |
LocalRpcInvocation
Local rpc invocation message containing the remote procedure name, its parameter types and the
corresponding call arguments.
|
class |
RemoteFencedMessage<F extends Serializable,P extends Serializable>
Remote
FencedMessage implementation. |
class |
RemoteHandshakeMessage
Handshake message between rpc endpoints.
|
class |
RemoteRpcInvocation
Remote rpc invocation message which is used when the actor communication is remote.
|
class |
RunAsync
Message for asynchronous runnable invocations.
|
class |
UnfencedMessage<P>
Wrapper class indicating a message which is not required to match the fencing token as it is used
by the
FencedMainThreadExecutable to run code in the main thread without a valid fencing
token. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.