Package 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 org.apache.flink.queryablestate.network.messages.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(org.apache.flink.queryablestate.KvStateID stateId, byte[] serializedKeyAndNamespace)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.queryablestate.KvStateID	getKvStateId()
byte[]	getSerializedKeyAndNamespace()
byte[]	serialize()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KvStateInternalRequest

public KvStateInternalRequest(org.apache.flink.queryablestate.KvStateID stateId,
                              byte[] serializedKeyAndNamespace)

Method Detail

getKvStateId

public org.apache.flink.queryablestate.KvStateID getKvStateId()

getSerializedKeyAndNamespace

public byte[] getSerializedKeyAndNamespace()

serialize

public byte[] serialize()

Specified by:

serialize in class org.apache.flink.queryablestate.network.messages.MessageBody