org.apache.paimon.iceberg

Class IcebergCommitCallback

java.lang.Object

org.apache.paimon.iceberg.IcebergCommitCallback

All Implemented Interfaces:

AutoCloseable, CommitCallback, TagCallback

public class IcebergCommitCallback
extends Object
implements CommitCallback, TagCallback

A CommitCallback to create Iceberg compatible metadata, so Iceberg readers can read Paimon's RawFile.

Constructor Summary

Constructors

Constructor and Description
IcebergCommitCallback(FileStoreTable table, String commitUser)

Method Summary

Modifier and Type	Method and Description
void	call(List<ManifestEntry> committedEntries, Snapshot snapshot)
static Path	catalogDatabasePath(FileStoreTable table)
static Path	catalogTableMetadataPath(FileStoreTable table)
void	close()
void	notifyCreation(String tagName)
void	notifyCreation(String tagName, long snapshotId)
void	notifyDeletion(String tagName)
void	retry(ManifestCommittable committable)

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergCommitCallback

public IcebergCommitCallback(FileStoreTable table,
                             String commitUser)

Method Detail

catalogTableMetadataPath

public static Path catalogTableMetadataPath(FileStoreTable table)

catalogDatabasePath

public static Path catalogDatabasePath(FileStoreTable table)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

call

public void call(List<ManifestEntry> committedEntries,
                 Snapshot snapshot)

Specified by:

call in interface CommitCallback

retry

public void retry(ManifestCommittable committable)

Specified by:

retry in interface CommitCallback

notifyCreation

public void notifyCreation(String tagName)

Specified by:

notifyCreation in interface TagCallback

notifyCreation

public void notifyCreation(String tagName,
                           long snapshotId)

Specified by:

notifyCreation in interface TagCallback

notifyDeletion

public void notifyDeletion(String tagName)

Specified by:

notifyDeletion in interface TagCallback