public class ManifestEntrySerializer extends VersionedObjectSerializer<ManifestEntry>
ManifestEntry
.rowSerializer
Constructor and Description |
---|
ManifestEntrySerializer() |
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() |
fromRow, toRow, versionType
deserialize, deserializeFromBytes, deserializeList, deserializeList, fieldTypes, numFields, serialize, serializeList, serializeList, serializeToBytes
public int getVersion()
VersionedObjectSerializer
getVersion
in class VersionedObjectSerializer<ManifestEntry>
public InternalRow convertTo(ManifestEntry entry)
convertTo
in class VersionedObjectSerializer<ManifestEntry>
public ManifestEntry convertFrom(int version, InternalRow row)
convertFrom
in class VersionedObjectSerializer<ManifestEntry>
public static java.util.function.Function<InternalRow,FileKind> kindGetter()
public static java.util.function.Function<InternalRow,BinaryRow> partitionGetter()
public static java.util.function.Function<InternalRow,Integer> bucketGetter()
public static java.util.function.Function<InternalRow,Integer> totalBucketGetter()
public static java.util.function.Function<InternalRow,String> fileNameGetter()
public static java.util.function.Function<InternalRow,Integer> levelGetter()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.