@@ -39,7 +39,9 @@ use parquet::arrow::arrow_reader::{
39
39
} ;
40
40
use parquet:: arrow:: async_reader:: AsyncFileReader ;
41
41
use parquet:: arrow:: { PARQUET_FIELD_ID_META_KEY , ParquetRecordBatchStreamBuilder , ProjectionMask } ;
42
- use parquet:: file:: metadata:: { ParquetMetaData , ParquetMetaDataReader , RowGroupMetaData } ;
42
+ use parquet:: file:: metadata:: {
43
+ PageIndexPolicy , ParquetMetaData , ParquetMetaDataReader , RowGroupMetaData ,
44
+ } ;
43
45
use parquet:: schema:: types:: { SchemaDescriptor , Type as ParquetType } ;
44
46
45
47
use crate :: arrow:: caching_delete_file_loader:: CachingDeleteFileLoader ;
@@ -1390,9 +1392,9 @@ impl<R: FileRead> AsyncFileReader for ArrowFileReader<R> {
1390
1392
async move {
1391
1393
let reader = ParquetMetaDataReader :: new ( )
1392
1394
. with_prefetch_hint ( self . metadata_size_hint )
1393
- . with_column_indexes ( self . preload_column_index )
1394
- . with_page_indexes ( self . preload_page_index )
1395
- . with_offset_indexes ( self . preload_offset_index ) ;
1395
+ . with_column_index_policy ( PageIndexPolicy :: from ( self . preload_column_index ) )
1396
+ . with_page_index_policy ( PageIndexPolicy :: from ( self . preload_page_index ) )
1397
+ . with_offset_index_policy ( PageIndexPolicy :: from ( self . preload_offset_index ) ) ;
1396
1398
let size = self . meta . size ;
1397
1399
let meta = reader. load_and_finish ( self , size) . await ?;
1398
1400
0 commit comments