refine code and add more test

apache · Oct 27, 2023 · efeb59d · efeb59d
1 parent 613b409
commit efeb59d
Show file tree

Hide file tree

Showing 2 changed files with 169 additions and 98 deletions.
diff --git a/crates/iceberg/src/avro/schema.rs b/crates/iceberg/src/avro/schema.rs
@@ -261,10 +261,7 @@ pub(crate) fn avro_decimal_schema(precision: usize, scale: usize) -> Result<Avro
     Ok(AvroSchema::Decimal(DecimalSchema {
         precision,
         scale,
-        inner: Box::new(avro_fixed_schema(
-            Type::decimal_required_bytes(precision as u32)? as usize,
-            None,
-        )?),
+        inner: Box::new(AvroSchema::Bytes),
     }))
 }
 
@@ -471,7 +468,7 @@ impl AvroSchemaVisitor for AvroSchemaToSchema {
                         )
                     })?;
                     match logical_type {
-                        "uuid" => Type::Primitive(PrimitiveType::Uuid),
+                        UUID_LOGICAL_TYPE => Type::Primitive(PrimitiveType::Uuid),
                         ty => {
                             return Err(Error::new(
                                 ErrorKind::FeatureUnsupported,