org.apache.paimon.utils

Class VersionedObjectSerializer<T>

java.lang.Object

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

org.apache.paimon.utils.VersionedObjectSerializer<T>

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

IndexManifestEntrySerializer, ManifestEntrySerializer, ManifestFileMetaSerializer

public abstract class VersionedObjectSerializer<T>
extends ObjectSerializer<T>

A ObjectSerializer for versioned serialization.

See Also:

Serialized Form

Field Summary

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

rowSerializer

Constructor Summary

Constructors

Constructor and Description
VersionedObjectSerializer(RowType rowType)

Method Summary

Modifier and Type	Method and Description
abstract T	convertFrom(int version, InternalRow row)
abstract InternalRow	convertTo(T record)
T	fromRow(InternalRow row) Convert a InternalRow to T.
abstract int	getVersion() Gets the version with which this serializer serializes.
InternalRow	toRow(T record) Convert a T to InternalRow.
static RowType	versionType(RowType rowType)

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

VersionedObjectSerializer

public VersionedObjectSerializer(RowType rowType)

Method Detail

versionType

public static RowType versionType(RowType rowType)

getVersion

public abstract int getVersion()

Gets the version with which this serializer serializes.

Returns:

The version of the serialization schema.

convertTo

public abstract InternalRow convertTo(T record)

convertFrom

public abstract T convertFrom(int version,
                              InternalRow row)

toRow

public final InternalRow toRow(T record)

Description copied from class: ObjectSerializer

Convert a T to InternalRow.

Specified by:

toRow in class ObjectSerializer<T>

fromRow

public final T fromRow(InternalRow row)

Description copied from class: ObjectSerializer

Convert a InternalRow to T.

Specified by:

fromRow in class ObjectSerializer<T>