org.apache.paimon.manifest

Class PartitionEntry

java.lang.Object

org.apache.paimon.manifest.PartitionEntry

@Public
public class PartitionEntry
extends Object

Entry representing a partition.

Constructor Summary

Constructors

Constructor and Description
PartitionEntry(BinaryRow partition, long recordCount, long fileSizeInBytes, long fileCount, long lastFileCreationTime)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	fileCount()
long	fileSizeInBytes()
static PartitionEntry	fromDataFile(BinaryRow partition, FileKind kind, DataFileMeta file)
static PartitionEntry	fromManifestEntry(ManifestEntry entry)
int	hashCode()
long	lastFileCreationTime()
static Collection<PartitionEntry>	merge(Collection<ManifestEntry> fileEntries)
static void	merge(Collection<PartitionEntry> from, Map<BinaryRow,PartitionEntry> to)
PartitionEntry	merge(PartitionEntry entry)
static Collection<PartitionEntry>	mergeSplits(Collection<DataSplit> splits)
BinaryRow	partition()
long	recordCount()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionEntry

public PartitionEntry(BinaryRow partition,
                      long recordCount,
                      long fileSizeInBytes,
                      long fileCount,
                      long lastFileCreationTime)

Method Detail

partition

public BinaryRow partition()

recordCount

public long recordCount()

fileSizeInBytes

public long fileSizeInBytes()

fileCount

public long fileCount()

lastFileCreationTime

public long lastFileCreationTime()

merge

public PartitionEntry merge(PartitionEntry entry)

fromManifestEntry

public static PartitionEntry fromManifestEntry(ManifestEntry entry)

fromDataFile

public static PartitionEntry fromDataFile(BinaryRow partition,
                                          FileKind kind,
                                          DataFileMeta file)

merge

public static Collection<PartitionEntry> merge(Collection<ManifestEntry> fileEntries)

mergeSplits

public static Collection<PartitionEntry> mergeSplits(Collection<DataSplit> splits)

merge

public static void merge(Collection<PartitionEntry> from,
                         Map<BinaryRow,PartitionEntry> to)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object