feat(parquet): add support decimal256 read/write in parquet

jorgecarleitao · Feb 21, 2023 · a70d37b · a70d37b
1 parent 615300b
commit a70d37b
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/io/parquet/write/schema.rs b/src/io/parquet/write/schema.rs
@@ -295,6 +295,14 @@ pub fn to_parquet_type(field: &Field) -> Result<ParquetType> {
                 None,
             )?)
         }
+        DataType::Decimal256(_, _) => Ok(ParquetType::try_from_primitive(
+            name,
+            PhysicalType::FixedLenByteArray(16),
+            repetition,
+            None,
+            None,
+            None,
+        )?),
         DataType::Interval(_) => Ok(ParquetType::try_from_primitive(
             name,
             PhysicalType::FixedLenByteArray(12),