org.apache.paimon.iceberg

Class AppendOnlyIcebergCommitCallback

java.lang.Object

org.apache.paimon.iceberg.AbstractIcebergCommitCallback

org.apache.paimon.iceberg.AppendOnlyIcebergCommitCallback

All Implemented Interfaces:

AutoCloseable, CommitCallback

public class AppendOnlyIcebergCommitCallback
extends AbstractIcebergCommitCallback

AbstractIcebergCommitCallback for append only tables.

Field Summary

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

table

Constructor Summary

Constructors

Constructor and Description
AppendOnlyIcebergCommitCallback(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, close, retry

Methods inherited from class java.lang.Object

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

Constructor Detail

AppendOnlyIcebergCommitCallback

public AppendOnlyIcebergCommitCallback(FileStoreTable table,
                                       String commitUser)

Method Detail

shouldAddFileToIceberg

protected boolean shouldAddFileToIceberg(DataFileMeta meta)

Specified by:

shouldAddFileToIceberg in class AbstractIcebergCommitCallback