public abstract class VersionedObjectSerializer<T> extends ObjectSerializer<T>
ObjectSerializer
for versioned serialization.rowSerializer
Constructor and Description |
---|
VersionedObjectSerializer(org.apache.flink.table.types.logical.RowType rowType) |
Modifier and Type | Method and Description |
---|---|
abstract T |
convertFrom(int version,
org.apache.flink.table.data.RowData row) |
abstract org.apache.flink.table.data.RowData |
convertTo(T record) |
T |
fromRow(org.apache.flink.table.data.RowData row)
Convert a
RowData to T . |
abstract int |
getVersion()
Gets the version with which this serializer serializes.
|
org.apache.flink.table.data.RowData |
toRow(T record)
Convert a
T to RowData . |
static org.apache.flink.table.types.logical.RowType |
versionType(org.apache.flink.table.types.logical.RowType rowType) |
deserialize, deserializeList, deserializeList, numFields, serialize, serializeList, serializeList
public VersionedObjectSerializer(org.apache.flink.table.types.logical.RowType rowType)
public static org.apache.flink.table.types.logical.RowType versionType(org.apache.flink.table.types.logical.RowType rowType)
public abstract int getVersion()
public abstract org.apache.flink.table.data.RowData convertTo(T record)
public abstract T convertFrom(int version, org.apache.flink.table.data.RowData row)
public final org.apache.flink.table.data.RowData toRow(T record)
ObjectSerializer
T
to RowData
.toRow
in class ObjectSerializer<T>
public final T fromRow(org.apache.flink.table.data.RowData row)
ObjectSerializer
RowData
to T
.fromRow
in class ObjectSerializer<T>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.