Package | Description |
---|---|
org.apache.paimon.service.messages | |
org.apache.paimon.service.server |
Modifier and Type | Method and Description |
---|---|
KvRequest |
KvRequest.KvRequestDeserializer.deserializeMessage(org.apache.paimon.shade.netty4.io.netty.buffer.ByteBuf buf) |
Modifier and Type | Method and Description |
---|---|
AbstractServerHandler<KvRequest,KvResponse> |
KvQueryServer.initializeHandler() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<KvResponse> |
KvServerHandler.handleRequest(long requestId,
KvRequest request) |
Constructor and Description |
---|
KvServerHandler(KvQueryServer server,
int serverId,
int numServers,
TableQuery lookup,
MessageSerializer<KvRequest,KvResponse> serializer,
ServiceRequestStats stats)
Create the handler used by the
KvQueryServer . |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.