public class ManifestEntrySerializer extends VersionedObjectSerializer<ManifestEntry>
ManifestEntry
.rowSerializer
Constructor and Description |
---|
ManifestEntrySerializer() |
Modifier and Type | Method and Description |
---|---|
ManifestEntry |
convertFrom(int version,
org.apache.flink.table.data.RowData row) |
org.apache.flink.table.data.RowData |
convertTo(ManifestEntry entry) |
int |
getVersion()
Gets the version with which this serializer serializes.
|
fromRow, toRow, versionType
deserialize, deserializeList, deserializeList, numFields, serialize, serializeList, serializeList
public int getVersion()
VersionedObjectSerializer
getVersion
in class VersionedObjectSerializer<ManifestEntry>
public org.apache.flink.table.data.RowData convertTo(ManifestEntry entry)
convertTo
in class VersionedObjectSerializer<ManifestEntry>
public ManifestEntry convertFrom(int version, org.apache.flink.table.data.RowData row)
convertFrom
in class VersionedObjectSerializer<ManifestEntry>
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.