org.apache.paimon

Class KeyValueSerializer

java.lang.Object

org.apache.paimon.utils.ObjectSerializer<KeyValue>

org.apache.paimon.KeyValueSerializer

All Implemented Interfaces:

Serializable

public class KeyValueSerializer
extends ObjectSerializer<KeyValue>

Serializer for KeyValue.

NOTE: InternalRow and KeyValue produced by this serializer are reused.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.utils.ObjectSerializer

rowSerializer

Constructor Summary

Constructors

Constructor and Description
KeyValueSerializer(RowType keyType, RowType valueType)

Method Summary

Modifier and Type	Method and Description
KeyValue	fromRow(InternalRow row) Convert a InternalRow to T.
KeyValue	getCopiedKv()
KeyValue	getReusedKv()
InternalRow	toRow(InternalRow key, long sequenceNumber, RowKind valueKind, InternalRow value)
InternalRow	toRow(KeyValue record) Convert a T to InternalRow.

Methods inherited from class org.apache.paimon.utils.ObjectSerializer

deserialize, deserializeFromBytes, deserializeList, deserializeList, fieldTypes, numFields, serialize, serializeList, serializeList, serializeToBytes

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyValueSerializer

public KeyValueSerializer(RowType keyType,
                          RowType valueType)

Method Detail

toRow

public InternalRow toRow(KeyValue record)

Description copied from class: ObjectSerializer

Convert a T to InternalRow.

Specified by:

toRow in class ObjectSerializer<KeyValue>

toRow

public InternalRow toRow(InternalRow key,
                         long sequenceNumber,
                         RowKind valueKind,
                         InternalRow value)

fromRow

public KeyValue fromRow(InternalRow row)

Description copied from class: ObjectSerializer

Convert a InternalRow to T.

Specified by:

fromRow in class ObjectSerializer<KeyValue>

getReusedKv

public KeyValue getReusedKv()

getCopiedKv

public KeyValue getCopiedKv()