org.apache.paimon.service.server

Class KvServerHandler

java.lang.Object

org.apache.paimon.shade.netty4.io.netty.channel.ChannelHandlerAdapter

org.apache.paimon.shade.netty4.io.netty.channel.ChannelInboundHandlerAdapter

org.apache.paimon.service.network.AbstractServerHandler<KvRequest,KvResponse>

org.apache.paimon.service.server.KvServerHandler

All Implemented Interfaces:

org.apache.paimon.shade.netty4.io.netty.channel.ChannelHandler, org.apache.paimon.shade.netty4.io.netty.channel.ChannelInboundHandler

@ChannelHandler.Sharable
public class KvServerHandler
extends AbstractServerHandler<KvRequest,KvResponse>

This handler dispatches asynchronous tasks, which query values and write the result to the channel.

The network threads receive the message, deserialize it and dispatch the query task. The actual query is handled in a separate thread as it might otherwise block the network threads (file I/O etc.).

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.shade.netty4.io.netty.channel.ChannelHandler

org.apache.paimon.shade.netty4.io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class org.apache.paimon.service.network.AbstractServerHandler

queryExecutor

Constructor Summary

Constructors

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.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<KvResponse>	handleRequest(long requestId, KvRequest request) Handles an incoming request and returns a CompletableFuture containing the corresponding response.
CompletableFuture<Void>	shutdown() Shuts down any handler-specific resources, e.g.

Methods inherited from class org.apache.paimon.service.network.AbstractServerHandler

channelActive, channelInactive, channelRead, exceptionCaught, getServerName

Methods inherited from class org.apache.paimon.shade.netty4.io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class org.apache.paimon.shade.netty4.io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.shade.netty4.io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

KvServerHandler

public KvServerHandler(KvQueryServer server,
                       int serverId,
                       int numServers,
                       TableQuery lookup,
                       MessageSerializer<KvRequest,KvResponse> serializer,
                       ServiceRequestStats stats)

Create the handler used by the KvQueryServer.

Parameters:

server - the KvQueryServer using the handler.

lookup - to be queried.

serializer - the MessageSerializer used to (de-) serialize the different messages.

stats - server statistics collector.

Method Detail

handleRequest

public CompletableFuture<KvResponse> handleRequest(long requestId,
                                                   KvRequest request)

Description copied from class: AbstractServerHandler

Handles an incoming request and returns a CompletableFuture containing the corresponding response.

NOTE: This method is called by multiple threads.

Specified by:

handleRequest in class AbstractServerHandler<KvRequest,KvResponse>

Parameters:

requestId - the id of the received request to be handled.

request - the request to be handled.

Returns:

A future with the response to be forwarded to the client.

shutdown

public CompletableFuture<Void> shutdown()

Description copied from class: AbstractServerHandler

Shuts down any handler-specific resources, e.g. thread pools etc and returns a CompletableFuture.

If an exception is thrown during the shutdown process, then that exception will be included in the returned future.

Specified by:

shutdown in class AbstractServerHandler<KvRequest,KvResponse>

Returns:

A CompletableFuture that will be completed when the shutdown process actually finishes.