Class KvStateResponse.KvStateResponseDeserializer
- java.lang.Object
-
- org.apache.flink.queryablestate.messages.KvStateResponse.KvStateResponseDeserializer
-
- All Implemented Interfaces:
MessageDeserializer<KvStateResponse>
- Enclosing class:
- KvStateResponse
public static class KvStateResponse.KvStateResponseDeserializer extends Object implements MessageDeserializer<KvStateResponse>
-
-
Constructor Summary
Constructors Constructor Description KvStateResponseDeserializer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description KvStateResponse
deserializeMessage(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
Deserializes a message contained in a byte buffer.
-
-
-
Method Detail
-
deserializeMessage
public KvStateResponse 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<KvStateResponse>
- Parameters:
buf
- the buffer containing the message.- Returns:
- The deserialized message.
-
-