org.apache.paimon.iceberg.manifest

Class IcebergDataFileMeta

java.lang.Object

org.apache.paimon.iceberg.manifest.IcebergDataFileMeta

public class IcebergDataFileMeta
extends Object

Iceberg data file meta.

See Iceberg spec.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IcebergDataFileMeta.Content See Iceberg data_file struct content field.

Method Summary

Modifier and Type	Method and Description
IcebergDataFileMeta.Content	content()
Long	contentOffset()
Long	contentSizeInBytes()
static IcebergDataFileMeta	create(IcebergDataFileMeta.Content content, String filePath, String fileFormat, BinaryRow partition, long recordCount, long fileSizeInBytes, IcebergSchema icebergSchema, SimpleStats stats, List<String> statsColumns)
static IcebergDataFileMeta	createForDeleteFile(IcebergDataFileMeta.Content content, String filePath, String fileFormat, BinaryRow partition, long recordCount, long fileSizeInBytes, String referencedDataFile, Long contentOffset, Long contentSizeInBytes)
boolean	equals(Object o)
String	fileFormat()
String	filePath()
long	fileSizeInBytes()
int	hashCode()
InternalMap	lowerBounds()
InternalMap	nullValueCounts()
BinaryRow	partition()
long	recordCount()
String	referencedDataFile()
static RowType	schema(RowType partitionType)
long	schemaId()
InternalMap	upperBounds()
IcebergDataFileMeta	withSchemaId(long schemaId)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static IcebergDataFileMeta create(IcebergDataFileMeta.Content content,
                                         String filePath,
                                         String fileFormat,
                                         BinaryRow partition,
                                         long recordCount,
                                         long fileSizeInBytes,
                                         IcebergSchema icebergSchema,
                                         SimpleStats stats,
                                         @Nullable
                                         List<String> statsColumns)

createForDeleteFile

public static IcebergDataFileMeta createForDeleteFile(IcebergDataFileMeta.Content content,
                                                      String filePath,
                                                      String fileFormat,
                                                      BinaryRow partition,
                                                      long recordCount,
                                                      long fileSizeInBytes,
                                                      String referencedDataFile,
                                                      Long contentOffset,
                                                      Long contentSizeInBytes)

content

public IcebergDataFileMeta.Content content()

filePath

public String filePath()

fileFormat

public String fileFormat()

partition

public BinaryRow partition()

recordCount

public long recordCount()

fileSizeInBytes

public long fileSizeInBytes()

nullValueCounts

public InternalMap nullValueCounts()

lowerBounds

public InternalMap lowerBounds()

upperBounds

public InternalMap upperBounds()

referencedDataFile

public String referencedDataFile()

contentOffset

public Long contentOffset()

contentSizeInBytes

public Long contentSizeInBytes()

schemaId

public long schemaId()

withSchemaId

public IcebergDataFileMeta withSchemaId(long schemaId)

schema

public static RowType schema(RowType partitionType)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object