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 Description KvStateClientProxyHandler(KvStateClientProxyImpl proxy, int queryExecutorThreads, MessageSerializer<KvStateRequest,KvStateResponse> serializer, KvStateRequestStats stats)
Create the handler used by theKvStateClientProxyImpl
. -
Uses of MessageSerializer in org.apache.flink.queryablestate.network
Constructors in org.apache.flink.queryablestate.network with parameters of type MessageSerializer Constructor 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 Description MessageSerializer<KvStateInternalRequest,KvStateResponse>
KvStateServerImpl. getSerializer()
Constructors in org.apache.flink.queryablestate.server with parameters of type MessageSerializer Constructor Description KvStateServerHandler(KvStateServerImpl server, KvStateRegistry kvStateRegistry, MessageSerializer<KvStateInternalRequest,KvStateResponse> serializer, KvStateRequestStats stats)
Create the handler used by theKvStateServerImpl
.
-