org.apache.paimon.utils

Class ObjectSerializer<T>

java.lang.Object

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

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

DataFileMetaSerializer, IcebergDataFileMetaSerializer, IcebergManifestEntrySerializer, IcebergManifestFileMetaSerializer, IcebergPartitionSummarySerializer, IdentifierSerializer, IndexFileMetaSerializer, IntObjectSerializer, KeyValueSerializer, KeyValueWithLevelNoReusingSerializer, VersionedObjectSerializer

public abstract class ObjectSerializer<T>
extends Object
implements Serializable

A serializer to serialize object by InternalRowSerializer.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected InternalRowSerializer	rowSerializer

Constructor Summary

Constructors

Constructor and Description
ObjectSerializer(RowType rowType)

Method Summary

Modifier and Type	Method and Description
T	deserialize(DataInputView source) De-serializes a record from the given source input view.
T	deserializeFromBytes(byte[] bytes)
List<T>	deserializeList(byte[] bytes)
List<T>	deserializeList(DataInputView source) De-serializes a record list from the given source input view.
DataType[]	fieldTypes()
abstract T	fromRow(InternalRow rowData) Convert a InternalRow to T.
int	numFields() Get the number of fields.
void	serialize(T record, DataOutputView target) Serializes the given record to the given target output view.
byte[]	serializeList(List<T> records)
void	serializeList(List<T> records, DataOutputView target) Serializes the given record list to the given target output view.
byte[]	serializeToBytes(T record)
abstract InternalRow	toRow(T record) Convert a T to InternalRow.

Methods inherited from class java.lang.Object

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

Field Detail

rowSerializer

protected final InternalRowSerializer rowSerializer

Constructor Detail

ObjectSerializer

public ObjectSerializer(RowType rowType)

Method Detail

numFields

public int numFields()

Get the number of fields.

fieldTypes

public DataType[] fieldTypes()

serialize

public final void serialize(T record,
                            DataOutputView target)
                     throws IOException

Serializes the given record to the given target output view.

Parameters:

record - The record to serialize.

target - The output view to write the serialized data to.

Throws:

IOException - Thrown, if the serialization encountered an I/O related error. Typically raised by the output view, which may have an underlying I/O channel to which it delegates.

deserialize

public final T deserialize(DataInputView source)
                    throws IOException

De-serializes a record from the given source input view.

Parameters:

source - The input view from which to read the data.

Returns:

The deserialized element.

Throws:

IOException - Thrown, if the de-serialization encountered an I/O related error. Typically raised by the input view, which may have an underlying I/O channel from which it reads.

serializeList

public final void serializeList(List<T> records,
                                DataOutputView target)
                         throws IOException

Serializes the given record list to the given target output view.

Throws:

IOException

serializeList

public final byte[] serializeList(List<T> records)
                           throws IOException

Throws:

IOException

deserializeList

public final List<T> deserializeList(DataInputView source)
                              throws IOException

De-serializes a record list from the given source input view.

Throws:

IOException

deserializeList

public final List<T> deserializeList(byte[] bytes)
                              throws IOException

Throws:

IOException

serializeToBytes

public byte[] serializeToBytes(T record)
                        throws IOException

Throws:

IOException

deserializeFromBytes

public T deserializeFromBytes(byte[] bytes)
                       throws IOException

Throws:

IOException

toRow

public abstract InternalRow toRow(T record)

Convert a T to InternalRow.

fromRow

public abstract T fromRow(InternalRow rowData)

Convert a InternalRow to T.