org.apache.paimon.service.server

Class KvQueryServer

java.lang.Object

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

org.apache.paimon.service.server.KvQueryServer

All Implemented Interfaces:

QueryServer

public class KvQueryServer
extends NetworkServer<KvRequest,KvResponse>
implements QueryServer

The default implementation of the QueryServer.

Constructor Summary

Constructors

Constructor and Description
KvQueryServer(int serverId, int numServers, String bindAddress, Iterator<Integer> bindPortIterator, Integer numEventLoopThreads, Integer numQueryThreads, TableQuery lookup, ServiceRequestStats stats)

Method Summary

Modifier and Type	Method and Description
InetSocketAddress	getServerAddress() Returns the address of this server.
AbstractServerHandler<KvRequest,KvResponse>	initializeHandler() Returns the handler to be used for serving the incoming requests.
void	shutdown() Shuts down the server and all related thread pools.
void	start() Starts the server by binding to the configured bind address (blocking).

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

getQueryExecutor, getServerName, isEventGroupShutdown, shutdownServer

Methods inherited from class java.lang.Object

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

Constructor Detail

KvQueryServer

public KvQueryServer(int serverId,
                     int numServers,
                     String bindAddress,
                     Iterator<Integer> bindPortIterator,
                     Integer numEventLoopThreads,
                     Integer numQueryThreads,
                     TableQuery lookup,
                     ServiceRequestStats stats)

Method Detail

initializeHandler

public AbstractServerHandler<KvRequest,KvResponse> initializeHandler()

Description copied from class: NetworkServer

Returns the handler to be used for serving the incoming requests.

Specified by:

initializeHandler in class NetworkServer<KvRequest,KvResponse>

start

public void start()
           throws Throwable

Description copied from class: NetworkServer

Starts the server by binding to the configured bind address (blocking).

Specified by:

start in interface QueryServer

Overrides:

start in class NetworkServer<KvRequest,KvResponse>

Throws:

Throwable

getServerAddress

public InetSocketAddress getServerAddress()

Description copied from class: NetworkServer

Returns the address of this server.

Specified by:

getServerAddress in interface QueryServer

Overrides:

getServerAddress in class NetworkServer<KvRequest,KvResponse>

Returns:

AbstractServerBase address

shutdown

public void shutdown()

Description copied from interface: QueryServer

Shuts down the server and all related thread pools.

Specified by:

shutdown in interface QueryServer