org.apache.paimon.iceberg

Class AbstractIcebergCommitCallback

java.lang.Object

org.apache.paimon.iceberg.AbstractIcebergCommitCallback

All Implemented Interfaces:

AutoCloseable, CommitCallback

Direct Known Subclasses:

AppendOnlyIcebergCommitCallback, PrimaryKeyIcebergCommitCallback

public abstract class AbstractIcebergCommitCallback
extends Object
implements CommitCallback

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

Field Summary

Fields

Modifier and Type	Field and Description
protected FileStoreTable	table

Constructor Summary

Constructors

Constructor and Description
AbstractIcebergCommitCallback(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	retry(ManifestCommittable committable)
protected abstract boolean	shouldAddFileToIceberg(DataFileMeta meta)

Methods inherited from class java.lang.Object

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

Field Detail

table

protected final FileStoreTable table

Constructor Detail

AbstractIcebergCommitCallback

public AbstractIcebergCommitCallback(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

shouldAddFileToIceberg

protected abstract boolean shouldAddFileToIceberg(DataFileMeta meta)