org.apache.paimon

Class KeyValueThinSerializer

java.lang.Object

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

org.apache.paimon.KeyValueThinSerializer

All Implemented Interfaces:

Serializable

public class KeyValueThinSerializer
extends ObjectSerializer<KeyValue>

Serialize KeyValue to InternalRow with ignorance of key. Only used to write KeyValue to disk.

See Also:

Serialized Form

Field Summary

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

rowSerializer

Constructor Summary

Constructors

Constructor and Description
KeyValueThinSerializer(RowType keyType, RowType valueType)

Method Summary

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

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

KeyValueThinSerializer

public KeyValueThinSerializer(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(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>