public class ManifestFileMeta extends Object
Constructor and Description |
---|
ManifestFileMeta(String fileName,
long fileSize,
long numAddedFiles,
long numDeletedFiles,
BinaryTableStats partitionStats,
long schemaId) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
String |
fileName() |
long |
fileSize() |
int |
hashCode() |
static List<ManifestFileMeta> |
merge(List<ManifestFileMeta> metas,
ManifestFile manifestFile,
long suggestedMetaSize,
int suggestedMinMetaCount)
Merge several
ManifestFileMeta s. |
long |
numAddedFiles() |
long |
numDeletedFiles() |
BinaryTableStats |
partitionStats() |
static org.apache.flink.table.types.logical.RowType |
schema() |
long |
schemaId() |
String |
toString() |
public ManifestFileMeta(String fileName, long fileSize, long numAddedFiles, long numDeletedFiles, BinaryTableStats partitionStats, long schemaId)
public String fileName()
public long fileSize()
public long numAddedFiles()
public long numDeletedFiles()
public BinaryTableStats partitionStats()
public long schemaId()
public static org.apache.flink.table.types.logical.RowType schema()
public static List<ManifestFileMeta> merge(List<ManifestFileMeta> metas, ManifestFile manifestFile, long suggestedMetaSize, int suggestedMinMetaCount)
ManifestFileMeta
s. ManifestEntry
s representing first adding and
then deleting the same data file will cancel each other.
NOTE: This method is atomic.
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.