Fixed error

jorgecarleitao · Mar 20, 2022 · 8e71b7e · 8e71b7e
1 parent be3a2be
commit 8e71b7e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/src/statistics/fixed_len_binary.rs b/src/statistics/fixed_len_binary.rs
@@ -15,7 +15,6 @@ pub struct FixedLenStatistics {
     pub distinct_count: Option<i64>,
     pub max_value: Option<Vec<u8>>,
     pub min_value: Option<Vec<u8>>,
-    pub(self) physical_type: PhysicalType,
 }
 
 impl Statistics for FixedLenStatistics {
@@ -24,7 +23,7 @@ impl Statistics for FixedLenStatistics {
     }
 
     fn physical_type(&self) -> &PhysicalType {
-        &self.physical_type
+        &self.primitive_type.physical_type
     }
 
     fn null_count(&self) -> Option<i64> {
@@ -64,7 +63,6 @@ pub fn read(
             x.truncate(size as usize);
             x
         }),
-        physical_type: PhysicalType::FixedLenByteArray(size),
     }))
 }
 

diff --git a/src/write/row_group.rs b/src/write/row_group.rs
@@ -92,7 +92,7 @@ where
                 .try_for_each(|spec| {
                     num_rows += spec.num_rows.ok_or_else(|| {
                         ParquetError::OutOfSpec(
-                            "All data pages must declare a number of rows on it".to_string(),
+                            "All data pages must declare the number of rows on it".to_string(),
                         )
                     })? as i64;
                     Result::Ok(())