Class KvStateResponse
- java.lang.Object
-
- org.apache.flink.queryablestate.network.messages.MessageBody
-
- org.apache.flink.queryablestate.messages.KvStateResponse
-
@Internal public class KvStateResponse extends MessageBody
The response containing the (serialized) state sent by theState Server
to theClient Proxy
, and then forwarded by the proxy to the originalQueryable State Client
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
KvStateResponse.KvStateResponseDeserializer
-
Constructor Summary
Constructors Constructor Description KvStateResponse(byte[] content)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]
getContent()
byte[]
serialize()
Serializes the message into a byte array.
-
-
-
Method Detail
-
getContent
public byte[] getContent()
-
serialize
public byte[] serialize()
Description copied from class:MessageBody
Serializes the message into a byte array.- Specified by:
serialize
in classMessageBody
- Returns:
- A byte array with the serialized content of the message.
-
-