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

Packages that use MessageBody

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

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

Subclasses of MessageBody in org.apache.flink.queryablestate.messages

Modifier and Type	Class and Description
class	KvStateInternalRequest The request to be forwarded by the Queryable State Client Proxy to the State Server of the Task Manager responsible for the requested state.
class	KvStateRequest The request to be sent by the Queryable State Client to the Client Proxy requesting a given state.
class	KvStateResponse The response containing the (serialized) state sent by the State Server to the Client Proxy, and then forwarded by the proxy to the original Queryable State Client.

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

Classes in org.apache.flink.queryablestate.network with type parameters of type MessageBody

Modifier and Type	Class and Description
class	AbstractServerBase<REQ extends MessageBody,RESP extends MessageBody> The base class for every server in the queryable state module.
class	AbstractServerBase<REQ extends MessageBody,RESP extends MessageBody> The base class for every server in the queryable state module.
class	AbstractServerHandler<REQ extends MessageBody,RESP extends MessageBody> The base class of every handler used by an AbstractServerBase.
class	AbstractServerHandler<REQ extends MessageBody,RESP extends MessageBody> The base class of every handler used by an AbstractServerBase.
class	Client<REQ extends MessageBody,RESP extends MessageBody> The base class for every client in the queryable state module.
class	Client<REQ extends MessageBody,RESP extends MessageBody> The base class for every client in the queryable state module.
class	ClientHandler<REQ extends MessageBody,RESP extends MessageBody> The handler used by a Client to handling incoming messages.
class	ClientHandler<REQ extends MessageBody,RESP extends MessageBody> The handler used by a Client to handling incoming messages.
interface	ClientHandlerCallback<RESP extends MessageBody> Callback for ClientHandler.

Uses of MessageBody in org.apache.flink.queryablestate.network.messages

Classes in org.apache.flink.queryablestate.network.messages with type parameters of type MessageBody

Modifier and Type	Interface and Description
interface	MessageDeserializer<M extends MessageBody> A utility used to deserialize a message.
class	MessageSerializer<REQ extends MessageBody,RESP extends MessageBody> Serialization and deserialization of messages exchanged between client and server.
class	MessageSerializer<REQ extends MessageBody,RESP extends MessageBody> Serialization and deserialization of messages exchanged between client and server.

Methods in org.apache.flink.queryablestate.network.messages with type parameters of type MessageBody

Modifier and Type	Method and Description
static <REQ extends MessageBody> org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf	MessageSerializer.serializeRequest(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufAllocator alloc, long requestId, REQ request) Serializes the request sent to the AbstractServerBase.
static <RESP extends MessageBody> org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf	MessageSerializer.serializeResponse(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufAllocator alloc, long requestId, RESP response) Serializes the response sent to the Client.