org.apache.paimon.service.messages

Class KvRequest

java.lang.Object

org.apache.paimon.service.network.messages.MessageBody

org.apache.paimon.service.messages.KvRequest

public class KvRequest
extends MessageBody

The request to query values for keys.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KvRequest.KvRequestDeserializer A deserializer for KvRequest.

Constructor Summary

Constructors

Constructor and Description
KvRequest(BinaryRow partition, int bucket, BinaryRow[] keys)

Method Summary

Modifier and Type	Method and Description
int	bucket()
boolean	equals(Object o)
int	hashCode()
BinaryRow[]	keys()
BinaryRow	partition()
byte[]	serialize() Serializes the message into a byte array.

Methods inherited from class java.lang.Object

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

Constructor Detail

KvRequest

public KvRequest(BinaryRow partition,
                 int bucket,
                 BinaryRow[] keys)

Method Detail

partition

public BinaryRow partition()

bucket

public int bucket()

keys

public BinaryRow[] keys()

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.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object