org.apache.paimon.table.sink

Interface CommitCallback

All Superinterfaces:

AutoCloseable

All Known Implementing Classes:

AbstractIcebergCommitCallback, AddPartitionCommitCallback, AppendOnlyIcebergCommitCallback, PrimaryKeyIcebergCommitCallback, TagPreviewCommitCallback

public interface CommitCallback
extends AutoCloseable

This callback will be called after a list of ManifestCommittables is committed.

As a usage example, we can extract what partitions are created from the ManifestCommittables and add these partitions into Hive metastore.

NOTE: To guarantee that this callback is called, if a failure occurs right after the commit, this callback might be called multiple times. Please make sure that your implementation is idempotent. That is, your callback can be called multiple times and still have the desired effect.

Method Summary

Modifier and Type	Method and Description
void	call(List<ManifestEntry> committedEntries, Snapshot snapshot)
void	retry(ManifestCommittable committable)

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

call

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

retry

void retry(ManifestCommittable committable)