From a70d37ba29b1f3e7223c1071a549cc7361c9d094 Mon Sep 17 00:00:00 2001 From: taichong Date: Tue, 21 Feb 2023 21:13:39 +0800 Subject: [PATCH] feat(parquet): add support decimal256 read/write in parquet --- src/io/parquet/write/schema.rs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/src/io/parquet/write/schema.rs b/src/io/parquet/write/schema.rs index ee60e98ac13..4465bf74000 100644 --- 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 { 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),