(iceberg-rust) branch main updated: Fix avro schema names for manifest and manifest_list (#182)

[fokko]

This is an automated email from the ASF dual-hosted git repository.

fokko pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg-rust.git


The following commit(s) were added to refs/heads/main by this push:
     new 390cd51  Fix avro schema names for manifest and manifest_list (#182)
390cd51 is described below

commit 390cd51f99e679b1cfbaf4acd8c57505db5229c6
Author: JanKaul <jank...@mailbox.org>
AuthorDate: Mon Feb 5 02:43:41 2024 +0100

    Fix avro schema names for manifest and manifest_list (#182)
    
    Co-authored-by: Fokko Driesprong <fo...@apache.org>
---
 crates/iceberg/src/spec/manifest.rs      | 4 ++--
 crates/iceberg/src/spec/manifest_list.rs | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/crates/iceberg/src/spec/manifest.rs 
b/crates/iceberg/src/spec/manifest.rs
index 1822468..818f9c6 100644
--- a/crates/iceberg/src/spec/manifest.rs
+++ b/crates/iceberg/src/spec/manifest.rs
@@ -662,7 +662,7 @@ mod _const_schema {
             )),
         ];
         let schema = Schema::builder().with_fields(fields).build()?;
-        schema_to_avro_schema("manifest", &schema)
+        schema_to_avro_schema("manifest_entry", &schema)
     }
 
     pub(super) fn manifest_schema_v1(partition_type: StructType) -> 
Result<AvroSchema, Error> {
@@ -696,7 +696,7 @@ mod _const_schema {
             )),
         ];
         let schema = Schema::builder().with_fields(fields).build().unwrap();
-        schema_to_avro_schema("manifest", &schema)
+        schema_to_avro_schema("manifest_entry", &schema)
     }
 }
 
diff --git a/crates/iceberg/src/spec/manifest_list.rs 
b/crates/iceberg/src/spec/manifest_list.rs
index 440b8d8..6dc4839 100644
--- a/crates/iceberg/src/spec/manifest_list.rs
+++ b/crates/iceberg/src/spec/manifest_list.rs
@@ -495,10 +495,10 @@ mod _const_schema {
     };
 
     pub(super) static MANIFEST_LIST_AVRO_SCHEMA_V1: Lazy<AvroSchema> =
-        Lazy::new(|| schema_to_avro_schema("manifest_list", 
&V1_SCHEMA).unwrap());
+        Lazy::new(|| schema_to_avro_schema("manifest_file", 
&V1_SCHEMA).unwrap());
 
     pub(super) static MANIFEST_LIST_AVRO_SCHEMA_V2: Lazy<AvroSchema> =
-        Lazy::new(|| schema_to_avro_schema("manifest_list", 
&V2_SCHEMA).unwrap());
+        Lazy::new(|| schema_to_avro_schema("manifest_file", 
&V2_SCHEMA).unwrap());
 }
 
 /// Entry in a manifest list.