public abstract class VersionedObjectSerializer<T> extends ObjectSerializer<T>
ObjectSerializer
for versioned serialization.rowSerializer
Constructor and Description |
---|
VersionedObjectSerializer(RowType rowType) |
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) |
deserialize, deserializeFromBytes, deserializeList, deserializeList, fieldTypes, numFields, serialize, serializeList, serializeList, serializeToBytes
public VersionedObjectSerializer(RowType rowType)
public abstract int getVersion()
public abstract InternalRow convertTo(T record)
public abstract T convertFrom(int version, InternalRow row)
public final InternalRow toRow(T record)
ObjectSerializer
T
to InternalRow
.toRow
in class ObjectSerializer<T>
public final T fromRow(InternalRow row)
ObjectSerializer
InternalRow
to T
.fromRow
in class ObjectSerializer<T>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.