use the decimal_type to replace the decimal logical (#3522)

apache · Jan 13, 2023 · 2191e72 · 2191e72
1 parent d49cd21
commit 2191e72
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/parquet/src/arrow/schema/primitive.rs b/parquet/src/arrow/schema/primitive.rs
@@ -235,14 +235,8 @@ fn from_byte_array(info: &BasicTypeInfo, precision: i32, scale: i32) -> Result<D
         (None, ConvertedType::BSON) => Ok(DataType::Binary),
         (None, ConvertedType::ENUM) => Ok(DataType::Binary),
         (None, ConvertedType::UTF8) => Ok(DataType::Utf8),
-        (Some(LogicalType::Decimal { precision, scale }), _) => Ok(DataType::Decimal128(
-            precision.try_into().unwrap(),
-            scale.try_into().unwrap(),
-        )),
-        (None, ConvertedType::DECIMAL) => Ok(DataType::Decimal128(
-            precision.try_into().unwrap(),
-            scale.try_into().unwrap(),
-        )),
+        (Some(LogicalType::Decimal { scale: s, precision: p }), _) => decimal_type(s, p),
+        (None, ConvertedType::DECIMAL) => decimal_type(scale, precision),
         (logical, converted) => Err(arrow_err!(
             "Unable to convert parquet BYTE_ARRAY logical type {:?} or converted type {}",
             logical,