org.apache.paimon.manifest

Class ManifestEntrySerializer

java.lang.Object

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

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

org.apache.paimon.manifest.ManifestEntrySerializer

All Implemented Interfaces:

Serializable

public class ManifestEntrySerializer
extends VersionedObjectSerializer<ManifestEntry>

Serializer for ManifestEntry.

See Also:

Serialized Form

Field Summary

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

rowSerializer

Constructor Summary

Constructors

Constructor and Description
ManifestEntrySerializer()

Method Summary

Modifier and Type	Method and Description
static java.util.function.Function<InternalRow,Integer>	bucketGetter()
ManifestEntry	convertFrom(int version, InternalRow row)
InternalRow	convertTo(ManifestEntry entry)
static java.util.function.Function<InternalRow,String>	fileNameGetter()
int	getVersion() Gets the version with which this serializer serializes.
static java.util.function.Function<InternalRow,FileKind>	kindGetter()
static java.util.function.Function<InternalRow,Integer>	levelGetter()
static java.util.function.Function<InternalRow,BinaryRow>	partitionGetter()
static java.util.function.Function<InternalRow,Integer>	totalBucketGetter()

Methods inherited from class org.apache.paimon.utils.VersionedObjectSerializer

fromRow, toRow, versionType

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

ManifestEntrySerializer

public ManifestEntrySerializer()

Method Detail

getVersion

public int getVersion()

Description copied from class: VersionedObjectSerializer

Gets the version with which this serializer serializes.

Specified by:

getVersion in class VersionedObjectSerializer<ManifestEntry>

Returns:

The version of the serialization schema.

convertTo

public InternalRow convertTo(ManifestEntry entry)

Specified by:

convertTo in class VersionedObjectSerializer<ManifestEntry>

convertFrom

public ManifestEntry convertFrom(int version,
                                 InternalRow row)

Specified by:

convertFrom in class VersionedObjectSerializer<ManifestEntry>

kindGetter

public static java.util.function.Function<InternalRow,FileKind> kindGetter()

partitionGetter

public static java.util.function.Function<InternalRow,BinaryRow> partitionGetter()

bucketGetter

public static java.util.function.Function<InternalRow,Integer> bucketGetter()

totalBucketGetter

public static java.util.function.Function<InternalRow,Integer> totalBucketGetter()

fileNameGetter

public static java.util.function.Function<InternalRow,String> fileNameGetter()

levelGetter

public static java.util.function.Function<InternalRow,Integer> levelGetter()