org.apache.paimon.iceberg.metadata

Class IcebergMetadata

java.lang.Object

org.apache.paimon.iceberg.metadata.IcebergMetadata

public class IcebergMetadata
extends Object

Iceberg's metadata json file.

See Iceberg spec.

Field Summary

Fields

Modifier and Type	Field and Description
static int	CURRENT_FORMAT_VERSION

Constructor Summary

Constructors

Constructor and Description
IcebergMetadata(int formatVersion, String tableUuid, String location, long lastSequenceNumber, long lastUpdatedMs, int lastColumnId, List<IcebergSchema> schemas, int currentSchemaId, List<IcebergPartitionSpec> partitionSpecs, int defaultSpecId, int lastPartitionId, List<IcebergSortOrder> sortOrders, int defaultSortOrderId, List<IcebergSnapshot> snapshots, int currentSnapshotId, Map<String,String> properties)
IcebergMetadata(String tableUuid, String location, long lastSequenceNumber, int lastColumnId, List<IcebergSchema> schemas, int currentSchemaId, List<IcebergPartitionSpec> partitionSpecs, int lastPartitionId, List<IcebergSnapshot> snapshots, int currentSnapshotId)

Method Summary

Modifier and Type	Method and Description
int	currentSchemaId()
IcebergSnapshot	currentSnapshot()
int	currentSnapshotId()
int	defaultSortOrderId()
int	defaultSpecId()
boolean	equals(Object o)
int	formatVersion()
static IcebergMetadata	fromJson(String json)
static IcebergMetadata	fromPath(FileIO fileIO, Path path)
int	hashCode()
int	lastColumnId()
int	lastPartitionId()
long	lastSequenceNumber()
long	lastUpdatedMs()
String	location()
List<IcebergPartitionSpec>	partitionSpecs()
Map<String,String>	properties()
List<IcebergSchema>	schemas()
List<IcebergSnapshot>	snapshots()
List<IcebergSortOrder>	sortOrders()
String	tableUuid()
String	toJson()

Methods inherited from class java.lang.Object

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

Field Detail

CURRENT_FORMAT_VERSION

public static final int CURRENT_FORMAT_VERSION

See Also:

Constant Field Values

Constructor Detail

IcebergMetadata

public IcebergMetadata(String tableUuid,
                       String location,
                       long lastSequenceNumber,
                       int lastColumnId,
                       List<IcebergSchema> schemas,
                       int currentSchemaId,
                       List<IcebergPartitionSpec> partitionSpecs,
                       int lastPartitionId,
                       List<IcebergSnapshot> snapshots,
                       int currentSnapshotId)

IcebergMetadata

public IcebergMetadata(int formatVersion,
                       String tableUuid,
                       String location,
                       long lastSequenceNumber,
                       long lastUpdatedMs,
                       int lastColumnId,
                       List<IcebergSchema> schemas,
                       int currentSchemaId,
                       List<IcebergPartitionSpec> partitionSpecs,
                       int defaultSpecId,
                       int lastPartitionId,
                       List<IcebergSortOrder> sortOrders,
                       int defaultSortOrderId,
                       List<IcebergSnapshot> snapshots,
                       int currentSnapshotId,
                       @Nullable
                       Map<String,String> properties)

Method Detail

formatVersion

public int formatVersion()

tableUuid

public String tableUuid()

location

public String location()

lastSequenceNumber

public long lastSequenceNumber()

lastUpdatedMs

public long lastUpdatedMs()

lastColumnId

public int lastColumnId()

schemas

public List<IcebergSchema> schemas()

currentSchemaId

public int currentSchemaId()

partitionSpecs

public List<IcebergPartitionSpec> partitionSpecs()

defaultSpecId

public int defaultSpecId()

lastPartitionId

public int lastPartitionId()

sortOrders

public List<IcebergSortOrder> sortOrders()

defaultSortOrderId

public int defaultSortOrderId()

snapshots

public List<IcebergSnapshot> snapshots()

currentSnapshotId

public int currentSnapshotId()

properties

public Map<String,String> properties()

currentSnapshot

public IcebergSnapshot currentSnapshot()

toJson

public String toJson()

fromJson

public static IcebergMetadata fromJson(String json)

fromPath

public static IcebergMetadata fromPath(FileIO fileIO,
                                       Path path)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object