From 16c4987689ae15d7a12a5e16986d0f691ff8a639 Mon Sep 17 00:00:00 2001
From: ZENOTME <st810918843@gmail.com>
Date: Thu, 14 Nov 2024 17:31:08 +0800
Subject: [PATCH] refine

---
 crates/iceberg/src/catalog/mod.rs |  2 +-
 crates/iceberg/src/transaction.rs | 22 +++++++---------------
 2 files changed, 8 insertions(+), 16 deletions(-)

diff --git a/crates/iceberg/src/catalog/mod.rs b/crates/iceberg/src/catalog/mod.rs
index 820c6d136..d53fb3f51 100644
--- a/crates/iceberg/src/catalog/mod.rs
+++ b/crates/iceberg/src/catalog/mod.rs
@@ -1055,7 +1055,7 @@ mod tests {
                 .with_manifest_list("s3://a/b/2.avro")
                 .with_summary(Summary {
                     operation: Operation::Append,
-                    other: HashMap::default(),
+                    additional_properties: HashMap::default(),
                 })
                 .build(),
         };
diff --git a/crates/iceberg/src/transaction.rs b/crates/iceberg/src/transaction.rs
index ceb629a98..9cc9371a1 100644
--- a/crates/iceberg/src/transaction.rs
+++ b/crates/iceberg/src/transaction.rs
@@ -29,8 +29,8 @@ use uuid::Uuid;
 use crate::error::Result;
 use crate::io::OutputFile;
 use crate::spec::{
-    DataFile, DataFileFormat, FormatVersion, Manifest, ManifestEntry, ManifestFile,
-    ManifestListWriter, ManifestMetadata, ManifestWriter, NullOrder, Operation, PartitionSpec,
+    BoundPartitionSpec, DataFile, DataFileFormat, FormatVersion, Manifest, ManifestEntry,
+    ManifestFile, ManifestListWriter, ManifestMetadata, ManifestWriter, NullOrder, Operation,
     Schema, Snapshot, SnapshotReference, SnapshotRetention, SortDirection, SortField, SortOrder,
     Struct, StructType, Summary, Transform, MAIN_BRANCH,
 };
@@ -203,7 +203,7 @@ impl<'a> FastAppendAction<'a> {
         schema: Schema,
         schema_id: i32,
         format_version: FormatVersion,
-        partition_spec: Arc<PartitionSpec>,
+        partition_spec: Arc<BoundPartitionSpec>,
         key_metadata: Vec<u8>,
         commit_uuid: String,
         snapshot_properties: HashMap<String, String>,
@@ -318,7 +318,7 @@ struct SnapshotProduceAction<'a> {
     snapshot_id: i64,
     schema_id: i32,
     format_version: FormatVersion,
-    partition_spec: Arc<PartitionSpec>,
+    partition_spec: Arc<BoundPartitionSpec>,
     schema: Schema,
     key_metadata: Vec<u8>,
 
@@ -341,7 +341,7 @@ impl<'a> SnapshotProduceAction<'a> {
         parent_snapshot_id: Option<i64>,
         schema_id: i32,
         format_version: FormatVersion,
-        partition_spec: Arc<PartitionSpec>,
+        partition_spec: Arc<BoundPartitionSpec>,
         schema: Schema,
         key_metadata: Vec<u8>,
         commit_uuid: String,
@@ -409,7 +409,7 @@ impl<'a> SnapshotProduceAction<'a> {
             }
             Self::validate_partition_value(
                 data_file.partition(),
-                &self.partition_spec.partition_type(&self.schema)?,
+                self.partition_spec.partition_type(),
             )?;
         }
         self.added_data_files.extend(data_files);
@@ -447,7 +447,7 @@ impl<'a> SnapshotProduceAction<'a> {
             })
             .collect();
         let manifest_meta = ManifestMetadata::builder()
-            .schema(self.schema.clone())
+            .schema(self.schema.clone().into())
             .schema_id(self.schema_id)
             .format_version(self.format_version)
             .partition_spec(self.partition_spec.as_ref().clone())
@@ -534,14 +534,6 @@ impl<'a> SnapshotProduceAction<'a> {
         manifest_list_writer.add_manifests(new_manifests.into_iter())?;
         manifest_list_writer.close().await?;
 
-        let input = self
-            .tx
-            .table
-            .file_io()
-            .new_input(manifest_list_path.clone())
-            .unwrap();
-        println!("{}", input.exists().await?);
-
         let commit_ts = chrono::Utc::now().timestamp_millis();
         let new_snapshot = Snapshot::builder()
             .with_manifest_list(manifest_list_path)