org.apache.flink.queryablestate.network.messages

Interface MessageDeserializer<M extends MessageBody>

Type Parameters:

M - The type of the message to be deserialized. It has to extend MessageBody

All Known Implementing Classes:

KvStateInternalRequest.KvStateInternalRequestDeserializer, KvStateRequest.KvStateRequestDeserializer, KvStateResponse.KvStateResponseDeserializer

@Internal
public interface MessageDeserializer<M extends MessageBody>

A utility used to deserialize a message.

Method Summary

Modifier and Type	Method and Description
M	deserializeMessage(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) Deserializes a message contained in a byte buffer.

Method Detail

deserializeMessage

M deserializeMessage(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)

Deserializes a message contained in a byte buffer.

Parameters:

buf - the buffer containing the message.

Returns:

The deserialized message.