Method commit_snapshot

crates/paimon/src/api/rest_api.rs:458–479

Commit a snapshot for a table. Corresponds to Python `RESTApi.commit_snapshot`.

(
        &self,
        identifier: &Identifier,
        table_uuid: &str,
        snapshot: &Snapshot,
        statistics: &[PartitionStatistics],
    )

    ///
    /// Corresponds to Python `RESTApi.commit_snapshot`.
    pub async fn commit_snapshot(
        &self,
        identifier: &Identifier,
        table_uuid: &str,
        snapshot: &Snapshot,
        statistics: &[PartitionStatistics],
    ) -> Result<bool> {
        let database = identifier.database();
        let table = identifier.object();
        validate_non_empty_multi(&[(database, "database name"), (table, "table name")])?;
        let path = self.resource_paths.commit_table(database, table);
        let request = serde_json::json!({
            "tableUuid": table_uuid,
            "snapshot": snapshot,
            "statistics": statistics,
        });
        let resp: serde_json::Value = self.client.post(&path, &request).await?;
        Ok(resp
            .get("success")
            .and_then(|v| v.as_bool())
            .unwrap_or(false))
    }

    /// Rollback a table to a specific snapshot.
    pub async fn rollback_to_snapshot(