Struct TableCommit 

pub struct TableCommit { /* private fields */ }

Table commit logic for Paimon write operations.

Provides atomic commit functionality including append, overwrite and truncate

Implementations

impl TableCommit

pub fn new(table: Table, commit_user: String) -> Self

pub async fn commit(&self, commit_messages: Vec<CommitMessage>) -> Result<()>

Commit new files in APPEND mode.

pub async fn overwrite(&self, commit_messages: Vec<CommitMessage>) -> Result<()>

Overwrite with dynamic partition detection.

Extracts the set of partitions touched by commit_messages and overwrites only those partitions. For unpartitioned tables this is a full table overwrite.

pub async fn truncate_partitions( &self, partitions: Vec<HashMap<String, Option<Datum>>>, ) -> Result<()>

Drop specific partitions (OVERWRITE with only deletes).

pub async fn truncate_table(&self) -> Result<()>

Truncate the entire table (OVERWRITE with no filter, only deletes).