Fix num_rows of page reader.
@@ -148,7 +148,7 @@ impl ParquetReader {
std::io::Cursor::new(chunk),
PageMetaData {
column_start: meta.offset,
- num_values: meta.length as i64,
+ num_values: rows as i64,
compression: meta.compression,
descriptor: descriptor.descriptor.clone(),
},
@@ -191,7 +191,7 @@ impl ParquetReader {
std::io::Cursor::new(chunk),
PageMetaData {
column_start: meta.offset,
- num_values: meta.length as i64,
+ num_values: rows as i64,
compression: meta.compression,
descriptor: descriptor.descriptor.clone(),
},
