org.apache.paimon.service.network

Class NetworkServer<REQ extends MessageBody,RESP extends MessageBody>

java.lang.Object

org.apache.paimon.service.network.NetworkServer<REQ,RESP>

Type Parameters:

REQ - the type of request the server expects to receive.

RESP - the type of response the server will send.

Direct Known Subclasses:

KvQueryServer

public abstract class NetworkServer<REQ extends MessageBody,RESP extends MessageBody>
extends Object

The base class for every server. It is using pure netty to send and receive messages of type MessageBody.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	NetworkServer(String serverName, String bindAddress, Iterator<Integer> bindPortIterator, Integer numEventLoopThreads, Integer numQueryThreads) Creates the NetworkServer.

Method Summary

Modifier and Type	Method and Description
protected ExecutorService	getQueryExecutor() Returns the thread-pool responsible for processing incoming requests.
InetSocketAddress	getServerAddress() Returns the address of this server.
String	getServerName() Gets the name of the server.
abstract AbstractServerHandler<REQ,RESP>	initializeHandler() Returns the handler to be used for serving the incoming requests.
boolean	isEventGroupShutdown()
CompletableFuture<Void>	shutdownServer() 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 java.lang.Object

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

Constructor Detail

NetworkServer

protected NetworkServer(String serverName,
                        String bindAddress,
                        Iterator<Integer> bindPortIterator,
                        Integer numEventLoopThreads,
                        Integer numQueryThreads)

Creates the NetworkServer.

The server needs to be started via start().

Parameters:

serverName - the name of the server

bindAddress - address to bind to

bindPortIterator - port to bind to

numEventLoopThreads - number of event loop threads

Method Detail

getQueryExecutor

protected ExecutorService getQueryExecutor()

Returns the thread-pool responsible for processing incoming requests.

getServerName

public String getServerName()

Gets the name of the server. This is useful for debugging.

Returns:

The name of the server.

initializeHandler

public abstract AbstractServerHandler<REQ,RESP> initializeHandler()

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

getServerAddress

public InetSocketAddress getServerAddress()

Returns the address of this server.

Returns:

AbstractServerBase address

Throws:

IllegalStateException - If server has not been started yet

start

public void start()
           throws Throwable

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

Throws:

Exception - If something goes wrong during the bind operation.

Throwable

shutdownServer

public CompletableFuture<Void> shutdownServer()

Shuts down the server and all related thread pools.

Returns:

A CompletableFuture that will be completed upon termination of the shutdown process.

isEventGroupShutdown

public boolean isEventGroupShutdown()