Skip to content

Commit dc023f5

Browse files
committed
Skip decoding statistics
1 parent 751b082 commit dc023f5

File tree

1 file changed

+6
-0
lines changed
  • parquet/src/file/metadata/thrift

1 file changed

+6
-0
lines changed

parquet/src/file/metadata/thrift/mod.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -456,6 +456,7 @@ fn read_column_metadata<'a>(
456456
11 => {
457457
column.dictionary_page_offset = Some(i64::read_thrift(&mut *prot)?);
458458
}
459+
/*
459460
12 => {
460461
column.statistics =
461462
convert_stats(column_descr, Some(Statistics::read_thrift(&mut *prot)?))?;
@@ -465,12 +466,14 @@ fn read_column_metadata<'a>(
465466
read_thrift_vec::<PageEncodingStats, ThriftSliceInputProtocol>(&mut *prot)?;
466467
column.encoding_stats = Some(val);
467468
}
469+
*/
468470
14 => {
469471
column.bloom_filter_offset = Some(i64::read_thrift(&mut *prot)?);
470472
}
471473
15 => {
472474
column.bloom_filter_length = Some(i32::read_thrift(&mut *prot)?);
473475
}
476+
/*
474477
16 => {
475478
let val = SizeStatistics::read_thrift(&mut *prot)?;
476479
column.unencoded_byte_array_data_bytes = val.unencoded_byte_array_data_bytes;
@@ -483,6 +486,7 @@ fn read_column_metadata<'a>(
483486
let val = GeospatialStatistics::read_thrift(&mut *prot)?;
484487
column.geo_statistics = convert_geo_stats(Some(val));
485488
}
489+
*/
486490
_ => {
487491
prot.skip(field_ident.field_type)?;
488492
}
@@ -536,6 +540,7 @@ fn read_column_chunk<'a>(
536540
3 => {
537541
col_meta_mask = read_column_metadata(&mut *prot, &mut col)?;
538542
}
543+
/**
539544
4 => {
540545
col.offset_index_offset = Some(i64::read_thrift(&mut *prot)?);
541546
}
@@ -548,6 +553,7 @@ fn read_column_chunk<'a>(
548553
7 => {
549554
col.column_index_length = Some(i32::read_thrift(&mut *prot)?);
550555
}
556+
**/
551557
#[cfg(feature = "encryption")]
552558
8 => {
553559
let val = ColumnCryptoMetaData::read_thrift(&mut *prot)?;

0 commit comments

Comments
 (0)