org.apache.paimon.table.sink

Interface TableCommit

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

BatchTableCommit, InnerTableCommit, StreamTableCommit

All Known Implementing Classes:

TableCommitImpl

@Public
public interface TableCommit
extends AutoCloseable

Create and commit snapshots of a Table. Snapshots are produced from CommitMessages, which themselves are generated by TableWrite.

Commit may fail and throw an exception. Before committing, it will first check for conflicts by checking if all files to be removed currently exists.

Since:

0.4.0

Method Summary

Modifier and Type	Method and Description
void	abort(List<CommitMessage> commitMessages) Abort an unsuccessful commit.

Methods inherited from interface java.lang.AutoCloseable

close

Method Detail

abort

void abort(List<CommitMessage> commitMessages)

Abort an unsuccessful commit. The data files will be deleted.