org.apache.paimon.iceberg

Class PrimaryKeyIcebergCommitCallback

java.lang.Object

org.apache.paimon.iceberg.AbstractIcebergCommitCallback

org.apache.paimon.iceberg.PrimaryKeyIcebergCommitCallback

All Implemented Interfaces:

AutoCloseable, CommitCallback

public class PrimaryKeyIcebergCommitCallback
extends AbstractIcebergCommitCallback

AbstractIcebergCommitCallback for primary key tables.

Field Summary

Fields inherited from class org.apache.paimon.iceberg.AbstractIcebergCommitCallback

table

Constructor Summary

Constructors

Constructor and Description
PrimaryKeyIcebergCommitCallback(FileStoreTable table, String commitUser)

Method Summary

Modifier and Type	Method and Description
protected boolean	shouldAddFileToIceberg(DataFileMeta meta)

Methods inherited from class org.apache.paimon.iceberg.AbstractIcebergCommitCallback

call, catalogDatabasePath, catalogTableMetadataPath, close, retry

Methods inherited from class java.lang.Object

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

Constructor Detail

PrimaryKeyIcebergCommitCallback

public PrimaryKeyIcebergCommitCallback(FileStoreTable table,
                                       String commitUser)

Method Detail

shouldAddFileToIceberg

protected boolean shouldAddFileToIceberg(DataFileMeta meta)

Specified by:

shouldAddFileToIceberg in class AbstractIcebergCommitCallback