Uses of Class
org.apache.flink.queryablestate.messages.KvStateRequest

Packages that use KvStateRequest

Package	Description
org.apache.flink.queryablestate.client.proxy
org.apache.flink.queryablestate.messages

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

Methods in org.apache.flink.queryablestate.client.proxy that return types with arguments of type KvStateRequest

Modifier and Type	Method and Description
AbstractServerHandler<KvStateRequest,KvStateResponse>	KvStateClientProxyImpl.initializeHandler()

Methods in org.apache.flink.queryablestate.client.proxy with parameters of type KvStateRequest

Modifier and Type	Method and Description
CompletableFuture<KvStateResponse>	KvStateClientProxyHandler.handleRequest(long requestId, KvStateRequest request)

Constructor parameters in org.apache.flink.queryablestate.client.proxy with type arguments of type KvStateRequest

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

Uses of KvStateRequest in org.apache.flink.queryablestate.messages

Methods in org.apache.flink.queryablestate.messages that return KvStateRequest

Modifier and Type	Method and Description
KvStateRequest	KvStateRequest.KvStateRequestDeserializer.deserializeMessage(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)