org.apache.paimon.manifest

Class ManifestEntry

java.lang.Object

org.apache.paimon.manifest.ManifestEntry

All Implemented Interfaces:

FileEntry

Direct Known Subclasses:

FilteredManifestEntry

@Public
public class ManifestEntry
extends Object
implements FileEntry

Entry of a manifest file, representing an addition / deletion of a data file.

Since:

0.9.0

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.manifest.FileEntry

FileEntry.Identifier

Field Summary

Fields

Modifier and Type	Field and Description
static RowType	SCHEMA

Constructor Summary

Constructors

Constructor and Description
ManifestEntry(FileKind kind, BinaryRow partition, int bucket, int totalBuckets, DataFileMeta file)

Method Summary

Modifier and Type	Method and Description
int	bucket()
ManifestEntry	copyWithoutStats()
boolean	equals(Object o)
String	externalPath()
List<String>	extraFiles()
DataFileMeta	file()
String	fileName()
ManifestEntry	fromBytes(byte[] bytes)
int	hashCode()
FileEntry.Identifier	identifier()
FileKind	kind()
int	level()
BinaryRow	maxKey()
BinaryRow	minKey()
BinaryRow	partition()
static long	recordCount(List<ManifestEntry> manifestEntries)
static long	recordCountAdd(List<ManifestEntry> manifestEntries)
static long	recordCountDelete(List<ManifestEntry> manifestEntries)
byte[]	toBytes()
String	toString()
int	totalBuckets()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.paimon.manifest.FileEntry

addFilter, deletedFilter, mergeEntries, mergeEntries, mergeEntries, readDeletedEntries, readDeletedEntries, readManifestEntries

Field Detail

SCHEMA

public static final RowType SCHEMA

Constructor Detail

ManifestEntry

public ManifestEntry(FileKind kind,
                     BinaryRow partition,
                     int bucket,
                     int totalBuckets,
                     DataFileMeta file)

Method Detail

kind

public FileKind kind()

Specified by:

kind in interface FileEntry

partition

public BinaryRow partition()

Specified by:

partition in interface FileEntry

bucket

public int bucket()

Specified by:

bucket in interface FileEntry

level

public int level()

Specified by:

level in interface FileEntry

fileName

public String fileName()

Specified by:

fileName in interface FileEntry

externalPath

@Nullable
public String externalPath()

Specified by:

externalPath in interface FileEntry

minKey

public BinaryRow minKey()

Specified by:

minKey in interface FileEntry

maxKey

public BinaryRow maxKey()

Specified by:

maxKey in interface FileEntry

extraFiles

public List<String> extraFiles()

Specified by:

extraFiles in interface FileEntry

totalBuckets

public int totalBuckets()

file

public DataFileMeta file()

identifier

public FileEntry.Identifier identifier()

Specified by:

identifier in interface FileEntry

copyWithoutStats

public ManifestEntry copyWithoutStats()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

recordCount

public static long recordCount(List<ManifestEntry> manifestEntries)

recordCountAdd

public static long recordCountAdd(List<ManifestEntry> manifestEntries)

recordCountDelete

public static long recordCountDelete(List<ManifestEntry> manifestEntries)

toBytes

public byte[] toBytes()
               throws IOException

Throws:

IOException

fromBytes

public ManifestEntry fromBytes(byte[] bytes)
                        throws IOException

Throws:

IOException