Class KvStateRequest.KvStateRequestDeserializer
- java.lang.Object
-
- org.apache.flink.queryablestate.messages.KvStateRequest.KvStateRequestDeserializer
-
- All Implemented Interfaces:
MessageDeserializer<KvStateRequest>
- Enclosing class:
- KvStateRequest
public static class KvStateRequest.KvStateRequestDeserializer extends Object implements MessageDeserializer<KvStateRequest>
Adeserializer
forKvStateRequest
.
-
-
Constructor Summary
Constructors Constructor Description KvStateRequestDeserializer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description KvStateRequest
deserializeMessage(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
Deserializes a message contained in a byte buffer.
-
-
-
Method Detail
-
deserializeMessage
public KvStateRequest deserializeMessage(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
Description copied from interface:MessageDeserializer
Deserializes a message contained in a byte buffer.- Specified by:
deserializeMessage
in interfaceMessageDeserializer<KvStateRequest>
- Parameters:
buf
- the buffer containing the message.- Returns:
- The deserialized message.
-
-