@Public public interface BatchTableCommit extends TableCommit
TableCommit
for batch processing. Recommended for one-time committing.Modifier and Type | Method and Description |
---|---|
void |
commit(List<CommitMessage> commitMessages)
Create a new commit.
|
void |
truncateTable()
Truncate table, like normal
commit(java.util.List<org.apache.paimon.table.sink.CommitMessage>) , files are not immediately deleted, they are only
logically deleted and will be deleted after the snapshot expires. |
abort
close
void commit(List<CommitMessage> commitMessages)
1. Snapshot expiration may occur according to three options:
2. Partition expiration may occur according to 'partition.expiration-time'. The partition check is expensive, so all partitions are not checked every time when invoking this method. The check frequency is controlled by 'partition.expiration-check-interval'. Partition expiration will create an 'OVERWRITE' snapshot.
commitMessages
- commit messages from table writevoid truncateTable()
commit(java.util.List<org.apache.paimon.table.sink.CommitMessage>)
, files are not immediately deleted, they are only
logically deleted and will be deleted after the snapshot expires.Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.