Uses of Class
org.apache.flink.queryablestate.network.messages.MessageSerializer

Packages that use MessageSerializer

Package	Description
org.apache.flink.queryablestate.client.proxy
org.apache.flink.queryablestate.network
org.apache.flink.queryablestate.server

Uses of MessageSerializer in org.apache.flink.queryablestate.client.proxy

Constructors in org.apache.flink.queryablestate.client.proxy with parameters of type MessageSerializer

Constructor and Description
KvStateClientProxyHandler(KvStateClientProxyImpl proxy, int queryExecutorThreads, MessageSerializer<KvStateRequest,KvStateResponse> serializer, KvStateRequestStats stats) Create the handler used by the KvStateClientProxyImpl.

Uses of MessageSerializer in org.apache.flink.queryablestate.network

Constructors in org.apache.flink.queryablestate.network with parameters of type MessageSerializer

Constructor and Description
AbstractServerHandler(AbstractServerBase<REQ,RESP> server, MessageSerializer<REQ,RESP> serializer, KvStateRequestStats stats) Create the handler.
Client(String clientName, int numEventLoopThreads, MessageSerializer<REQ,RESP> serializer, KvStateRequestStats stats) Creates a client with the specified number of event loop threads.
ClientHandler(String clientName, MessageSerializer<REQ,RESP> serializer, ClientHandlerCallback<RESP> callback) Creates a handler with the callback.

Uses of MessageSerializer in org.apache.flink.queryablestate.server

Methods in org.apache.flink.queryablestate.server that return MessageSerializer

Modifier and Type	Method and Description
MessageSerializer<KvStateInternalRequest,KvStateResponse>	KvStateServerImpl.getSerializer()

Constructors in org.apache.flink.queryablestate.server with parameters of type MessageSerializer

Constructor and Description
KvStateServerHandler(KvStateServerImpl server, KvStateRegistry kvStateRegistry, MessageSerializer<KvStateInternalRequest,KvStateResponse> serializer, KvStateRequestStats stats) Create the handler used by the KvStateServerImpl.