Package | Description |
---|---|
org.apache.paimon.service.messages | |
org.apache.paimon.service.network | |
org.apache.paimon.service.network.messages |
Modifier and Type | Class and Description |
---|---|
class |
KvRequest
The request to query values for keys.
|
class |
KvResponse
The response containing values sent by the Server to the Client.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractServerHandler<REQ extends MessageBody,RESP extends MessageBody>
The base class of every handler used by an
NetworkServer . |
class |
AbstractServerHandler<REQ extends MessageBody,RESP extends MessageBody>
The base class of every handler used by an
NetworkServer . |
class |
ClientHandler<REQ extends MessageBody,RESP extends MessageBody>
The handler used by a
NetworkClient to handling incoming messages. |
class |
ClientHandler<REQ extends MessageBody,RESP extends MessageBody>
The handler used by a
NetworkClient to handling incoming messages. |
interface |
ClientHandlerCallback<RESP extends MessageBody>
Callback for
ClientHandler . |
class |
NetworkClient<REQ extends MessageBody,RESP extends MessageBody>
The base class for every client.
|
class |
NetworkClient<REQ extends MessageBody,RESP extends MessageBody>
The base class for every client.
|
class |
NetworkServer<REQ extends MessageBody,RESP extends MessageBody>
The base class for every server.
|
class |
NetworkServer<REQ extends MessageBody,RESP extends MessageBody>
The base class for every server.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MessageDeserializer<M extends MessageBody>
A utility used to deserialize a
message . |
class |
MessageSerializer<REQ extends MessageBody,RESP extends MessageBody>
Serialization and deserialization of messages exchanged between
NetworkClient and NetworkServer . |
class |
MessageSerializer<REQ extends MessageBody,RESP extends MessageBody>
Serialization and deserialization of messages exchanged between
NetworkClient and NetworkServer . |
Modifier and Type | Method and Description |
---|---|
static <REQ extends MessageBody> |
MessageSerializer.serializeRequest(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBufAllocator alloc,
long requestId,
REQ request)
Serializes the request sent to the
NetworkServer . |
static <RESP extends MessageBody> |
MessageSerializer.serializeResponse(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBufAllocator alloc,
long requestId,
RESP response)
Serializes the response sent to the
NetworkClient . |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.