KvStateInternalRequest (Flink : 2.0-SNAPSHOT API)

java.lang.Object
- org.apache.flink.queryablestate.network.messages.MessageBody
- - org.apache.flink.queryablestate.messages.KvStateInternalRequest

```
@Internal
public class KvStateInternalRequest
extends MessageBody
```
The request to be forwarded by the Queryable State Client Proxy to the State Server of the Task Manager responsible for the requested state.

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class KvStateInternalRequest.KvStateInternalRequestDeserializer
A deserializer for KvStateInternalRequest.

Constructor Summary

Constructors
Constructor Description

KvStateInternalRequest(KvStateID stateId, byte[] serializedKeyAndNamespace)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`KvStateID`	`getKvStateId()`
`byte[]`	`getSerializedKeyAndNamespace()`
`byte[]`	`serialize()`	Serializes the message into a byte array.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - KvStateInternalRequest
```
public KvStateInternalRequest(KvStateID stateId,
                              byte[] serializedKeyAndNamespace)
```
- Method Detail
  - getKvStateId
```
public KvStateID getKvStateId()
```
  - getSerializedKeyAndNamespace
```
public byte[] getSerializedKeyAndNamespace()
```
  - serialize
```
public byte[] serialize()
```
    Description copied from class: MessageBody
    
    Serializes the message into a byte array.
    
    Specified by:
    
    serialize in class MessageBody
    
    Returns:
    
    A byte array with the serialized content of the message.