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

Packages that use KvStateInternalRequest

Package	Description
org.apache.flink.queryablestate.messages
org.apache.flink.queryablestate.server

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

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

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

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

Methods in org.apache.flink.queryablestate.server that return types with arguments of type KvStateInternalRequest

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

Methods in org.apache.flink.queryablestate.server with parameters of type KvStateInternalRequest

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

Constructor parameters in org.apache.flink.queryablestate.server with type arguments of type KvStateInternalRequest

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