/// Read IOx statistics (including timestamp range) from parquet metadata.
Read IOx statistics (including timestamp range) from parquet metadata.
Read IOx statistics ( including timestamp range ) from parquet metadata .
pub fn read_statistics_from_parquet_metadata(
    parquet_md: &ParquetMetaData,
    schema: &Schema,
    table_name: &str,
) -> Result<TableSummary> {
    let mut table_summary_agg: Option<TableSummary> = None;
    for (row_group_idx, row_group) in parquet_md.row_groups().iter().enumerate() {
        let table_summary =
            read_statistics_from_parquet_row_group(row_group, row_group_idx, schema, table_name)?;
        match table_summary_agg.as_mut() {
            Some(existing) => existing.update_from(&table_summary),
            None => table_summary_agg = Some(table_summary),
        }
    }
    table_summary_agg.context(NoRowGroup)
}
pub fn read_statistics_from_parquet_metadata ( parquet_md : & ParquetMetaData , schema : & Schema , table_name : & str , ) -> Result < TableSummary > { let mut table_summary_agg : Option < TableSummary > = None ; for ( row_group_idx , row_group ) in parquet_md . row_groups ( ) . iter ( ) . enumerate ( ) { let table_summary = read_statistics_from_parquet_row_group ( row_group , row_group_idx , schema , table_name ) ? ; match table_summary_agg . as_mut ( ) { Some ( existing ) => existing . update_from ( & table_summary ) , None => table_summary_agg = Some ( table_summary ) , } } table_summary_agg . context ( NoRowGroup ) }
Read IOx statistics (including timestamp range) from parquet metadata.
Read IOx statistics ( including timestamp range ) from parquet metadata .
parquet_md
&ParquetMetaData
schema
&Schema
table_name
&str