diff --git a/src/io/parquet/read/statistics/fixlen.rs b/src/io/parquet/read/statistics/fixlen.rs index 6c8ee9ddb8b..2cbe8e97751 100644 --- a/src/io/parquet/read/statistics/fixlen.rs +++ b/src/io/parquet/read/statistics/fixlen.rs @@ -1,11 +1,9 @@ use std::any::Any; use std::convert::{TryFrom, TryInto}; -use super::super::schema; use super::primitive::PrimitiveStatistics; use crate::datatypes::DataType; use crate::error::{ArrowError, Result}; -use parquet2::schema::types::ParquetType; use parquet2::{ schema::types::PhysicalType, statistics::{ @@ -102,10 +100,8 @@ impl TryFrom<(&ParquetFixedLenStatistics, DataType)> for PrimitiveStatistics Result> { - let data_type = schema::to_data_type(type_)?.unwrap(); - use DataType::*; Ok(match data_type { Decimal(_, _) => Box::new(PrimitiveStatistics::::try_from((stats, data_type))?), diff --git a/src/io/parquet/read/statistics/mod.rs b/src/io/parquet/read/statistics/mod.rs index 9ad29c19b8a..dcee10a2126 100644 --- a/src/io/parquet/read/statistics/mod.rs +++ b/src/io/parquet/read/statistics/mod.rs @@ -89,7 +89,7 @@ fn _deserialize_statistics( } PhysicalType::FixedLenByteArray(_) => { let stats = stats.as_any().downcast_ref().unwrap(); - fixlen::statistics_from_fix_len(stats, stats.descriptor.type_()) + fixlen::statistics_from_fix_len(stats, data_type) } _ => Err(ArrowError::NotYetImplemented( "Reading Fixed-len array statistics is not yet supported".to_string(),