@Internal public class KvStateInternalRequest extends MessageBody
Queryable State Client Proxy
to the State Server
of the Task Manager responsible for the requested state.Modifier and Type | Class and Description |
---|---|
static class |
KvStateInternalRequest.KvStateInternalRequestDeserializer
|
Constructor and Description |
---|
KvStateInternalRequest(KvStateID stateId,
byte[] serializedKeyAndNamespace) |
Modifier and Type | Method and Description |
---|---|
KvStateID |
getKvStateId() |
byte[] |
getSerializedKeyAndNamespace() |
byte[] |
serialize()
Serializes the message into a byte array.
|
public KvStateInternalRequest(KvStateID stateId, byte[] serializedKeyAndNamespace)
public KvStateID getKvStateId()
public byte[] getSerializedKeyAndNamespace()
public byte[] serialize()
MessageBody
serialize
in class MessageBody
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.