Interface MessageDeserializer<M extends MessageBody>
-
- Type Parameters:
M
- The type of the message to be deserialized. It has to extendMessageBody
- All Known Implementing Classes:
KvStateInternalRequest.KvStateInternalRequestDeserializer
,KvStateRequest.KvStateRequestDeserializer
,KvStateResponse.KvStateResponseDeserializer
@Internal public interface MessageDeserializer<M extends MessageBody>
A utility used to deserialize amessage
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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.
-
-