org.apache.flink.queryablestate.messages

Class KvStateInternalRequest

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 and Description
static class	KvStateInternalRequest.KvStateInternalRequestDeserializer A deserializer for KvStateInternalRequest.

Constructor Summary

Constructors

Constructor and Description
KvStateInternalRequest(KvStateID stateId, byte[] serializedKeyAndNamespace)

Method Summary

Modifier and Type	Method and 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.