| 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–2025 The Apache Software Foundation. All rights reserved.