MCPcopy Create free account
hub / github.com/apache/paimon-rust / commit

Method commit

crates/paimon/src/table/table_commit.rs:95–107  ·  view source on GitHub ↗

Commit new files in APPEND mode.

(&self, commit_messages: Vec<CommitMessage>)

Source from the content-addressed store, hash-verified

93
94 /// Commit new files in APPEND mode.
95 pub async fn commit(&self, commit_messages: Vec<CommitMessage>) -> Result<()> {
96 if commit_messages.is_empty() {
97 return Ok(());
98 }
99
100 let entries = self.messages_to_entries(&commit_messages);
101 let new_index_entries = self.messages_to_index_entries(&commit_messages);
102 self.try_commit(CommitEntriesPlan::Direct {
103 entries,
104 new_index_entries,
105 })
106 .await
107 }
108
109 /// Overwrite partitions with new data.
110 ///

Calls 4

messages_to_entriesMethod · 0.80
try_commitMethod · 0.80
is_emptyMethod · 0.45